org.apache.logging.log4j.flume.appender

Class FlumeEmbeddedManager

java.lang.Object

org.apache.logging.log4j.core.appender.AbstractManager

org.apache.logging.log4j.flume.appender.AbstractFlumeManager

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

All Implemented Interfaces:

AutoCloseable

public class FlumeEmbeddedManager
extends AbstractFlumeManager

Field Summary

Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager

count, LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlumeEmbeddedManager(String name, String shortName, org.apache.flume.agent.embedded.EmbeddedAgent agent) Constructor

Method Summary

Modifier and Type	Method and Description
static FlumeEmbeddedManager	getManager(String name, Agent[] agents, org.apache.logging.log4j.core.config.Property[] properties, int batchSize, String dataDir) Returns a FlumeEmbeddedManager.
protected boolean	releaseSub(long timeout, TimeUnit timeUnit)
void	send(org.apache.flume.Event event)

Methods inherited from class org.apache.logging.log4j.core.appender.AbstractManager

close, getContentFormat, getCount, getLoggerContext, getManager, getName, hasManager, log, logDebug, logError, logger, logWarn, narrow, release, stop, updateData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlumeEmbeddedManager

protected FlumeEmbeddedManager(String name,
                               String shortName,
                               org.apache.flume.agent.embedded.EmbeddedAgent agent)

Constructor

Parameters:

name - The unique name of this manager.

shortName - The short version of the agent name.

agent - The embedded agent.

Method Detail

getManager

public static FlumeEmbeddedManager getManager(String name,
                                              Agent[] agents,
                                              org.apache.logging.log4j.core.config.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(org.apache.flume.Event event)

Specified by:

send in class AbstractFlumeManager

releaseSub

protected boolean releaseSub(long timeout,
                             TimeUnit timeUnit)

Overrides:

releaseSub in class org.apache.logging.log4j.core.appender.AbstractManager