|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.logging.log4j.core.appender.AbstractManager
org.apache.logging.log4j.flume.appender.AbstractFlumeManager
org.apache.logging.log4j.flume.appender.FlumeAvroManager
public class FlumeAvroManager
Manager for FlumeAvroAppenders.
Field Summary | |
---|---|
static int |
DEFAULT_RECONNECTION_DELAY
The default reconnection delay (500 milliseconds or .5 seconds). |
Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager |
---|
count, LOGGER |
Constructor Summary | |
---|---|
protected |
FlumeAvroManager(String name,
String shortName,
Agent[] agents,
int batchSize)
Constructor |
Method Summary | |
---|---|
Agent[] |
getAgents()
Returns the agents. |
int |
getCurrent()
Returns the index of the current agent. |
static FlumeAvroManager |
getManager(String name,
Agent[] agents,
int batchSize)
Returns a FlumeAvroManager. |
protected void |
releaseSub()
|
void |
send(FlumeEvent event,
int delay,
int retries)
|
Methods inherited from class org.apache.logging.log4j.core.appender.AbstractManager |
---|
getCount, getManager, getName, hasManager, release |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int DEFAULT_RECONNECTION_DELAY
Constructor Detail |
---|
protected FlumeAvroManager(String name, String shortName, Agent[] agents, int batchSize)
name
- The unique name of this manager.agents
- An array of Agents.batchSize
- The number of evetns to include in a batch.Method Detail |
---|
public static FlumeAvroManager getManager(String name, Agent[] agents, int batchSize)
name
- The name of the manager.agents
- The agents to use.batchSize
- The number of events to include in a batch.
public Agent[] getAgents()
public int getCurrent()
public void send(FlumeEvent event, int delay, int retries)
send
in class AbstractFlumeManager
protected void releaseSub()
releaseSub
in class org.apache.logging.log4j.core.appender.AbstractManager
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Copyright © 1999-2013 Apache Software Foundation. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.