org.apache.logging.log4j.flume.appender
Class FlumeEmbeddedManager

java.lang.Object
  extended by org.apache.logging.log4j.core.appender.AbstractManager
      extended by org.apache.logging.log4j.flume.appender.AbstractFlumeManager
          extended by org.apache.logging.log4j.flume.appender.FlumeEmbeddedManager

public class FlumeEmbeddedManager
extends AbstractFlumeManager


Field Summary
protected static String SOURCE_NAME
          Name for the Flume source
 
Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager
count, LOGGER
 
Constructor Summary
protected FlumeEmbeddedManager(String name, String shortName, FlumeNode node)
          Constructor
 
Method Summary
static FlumeEmbeddedManager getManager(String name, Agent[] agents, Property[] properties, int batchSize, String dataDir)
          Returns a FlumeEmbeddedManager.
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

SOURCE_NAME

protected static final String SOURCE_NAME
Name for the Flume source

See Also:
Constant Field Values
Constructor Detail

FlumeEmbeddedManager

protected FlumeEmbeddedManager(String name,
                               String shortName,
                               FlumeNode node)
Constructor

Parameters:
name - The unique name of this manager.
node - The Flume Node.
Method Detail

getManager

public static FlumeEmbeddedManager getManager(String name,
                                              Agent[] agents,
                                              Property[] properties,
                                              int batchSize,
                                              String dataDir)
Returns a FlumeEmbeddedManager.

Parameters:
name - The name of the manager.
agents - The agents to use.
properties - Properties for the embedded manager.
batchSize - The number of events to include in a batch.
dataDir - The directory where the Flume FileChannel should write to.
Returns:
A FlumeAvroManager.

send

public void send(FlumeEvent event,
                 int delay,
                 int retries)
Specified by:
send in class AbstractFlumeManager

releaseSub

protected void releaseSub()
Overrides:
releaseSub in class AbstractManager


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.