org.apache.logging.log4j.flume.appender

Class FlumePersistentManager

java.lang.Object

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

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

org.apache.logging.log4j.flume.appender.FlumeAvroManager

org.apache.logging.log4j.flume.appender.FlumePersistentManager

All Implemented Interfaces:

AutoCloseable

public class FlumePersistentManager
extends FlumeAvroManager

Manager that persists data to Berkeley DB before passing it on to Flume.

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_PROVIDER Attribute name for the key provider.

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

count, LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlumePersistentManager(String name, String shortName, Agent[] agents, int batchSize, int retries, int connectionTimeout, int requestTimeout, int delay, com.sleepycat.je.Database database, com.sleepycat.je.Environment environment, SecretKey secretKey, int lockTimeoutRetryCount) Constructor

Method Summary

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

Methods inherited from class org.apache.logging.log4j.flume.appender.FlumeAvroManager

getAgents, getBatchSize, getConnectTimeoutMillis, getCurrent, getDelayMillis, getManager, getRequestTimeoutMillis, getRetries, send

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

Field Detail

KEY_PROVIDER

public static final String KEY_PROVIDER

Attribute name for the key provider.

See Also:

Constant Field Values

Constructor Detail

FlumePersistentManager

protected FlumePersistentManager(String name,
                                 String shortName,
                                 Agent[] agents,
                                 int batchSize,
                                 int retries,
                                 int connectionTimeout,
                                 int requestTimeout,
                                 int delay,
                                 com.sleepycat.je.Database database,
                                 com.sleepycat.je.Environment environment,
                                 SecretKey secretKey,
                                 int lockTimeoutRetryCount)

Constructor

Parameters:

name - The unique name of this manager.

shortName - Original name for the Manager.

agents - An array of Agents.

batchSize - The number of events to include in a batch.

retries - The number of times to retry connecting before giving up.

connectionTimeout - The amount of time to wait for a connection to be established.

requestTimeout - The amount of time to wair for a response to a request.

delay - The amount of time to wait between retries.

database - The database to write to.

environment - The database environment.

secretKey - The SecretKey to use for encryption.

lockTimeoutRetryCount - The number of times to retry a lock timeout.

Method Detail

getManager

public static FlumePersistentManager getManager(String name,
                                                Agent[] agents,
                                                org.apache.logging.log4j.core.config.Property[] properties,
                                                int batchSize,
                                                int retries,
                                                int connectionTimeout,
                                                int requestTimeout,
                                                int delayMillis,
                                                int lockTimeoutRetryCount,
                                                String dataDir)

Returns a FlumeAvroManager.

Parameters:

name - The name of the manager.

agents - The agents to use.

properties - Properties to pass to the Manager.

batchSize - The number of events to include in a batch.

retries - The number of times to retry connecting before giving up.

connectionTimeout - The amount of time to wait to establish a connection.

requestTimeout - The amount of time to wait for a response to a request.

delayMillis - Amount of time to delay before delivering a batch.

lockTimeoutRetryCount - The number of times to retry after a lock timeout.

dataDir - The location of the Berkeley database.

Returns:

A FlumeAvroManager.

send

public void send(org.apache.flume.Event event)

Overrides:

send in class FlumeAvroManager

releaseSub

protected boolean releaseSub(long timeout,
                             TimeUnit timeUnit)

Overrides:

releaseSub in class FlumeAvroManager