org.apache.logging.log4j.flume.appender

Class FlumeAvroManager

java.lang.Object

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

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

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

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

FlumePersistentManager

public class FlumeAvroManager
extends AbstractFlumeManager

Manager for FlumeAvroAppenders.

Field Summary

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

count, LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlumeAvroManager(String name, String shortName, Agent[] agents, int batchSize, int delayMillis, int retries, int connectTimeout, int requestTimeout) Constructor

Method Summary

Modifier and Type	Method and Description
Agent[]	getAgents() Returns the agents.
int	getBatchSize()
int	getConnectTimeoutMillis()
int	getCurrent() Returns the index of the current agent.
int	getDelayMillis()
static FlumeAvroManager	getManager(String name, Agent[] agents, int batchSize, int delayMillis, int retries, int connectTimeoutMillis, int requestTimeoutMillis) Returns a FlumeAvroManager.
int	getRequestTimeoutMillis()
int	getRetries()
protected boolean	releaseSub(long timeout, TimeUnit timeUnit)
void	send(BatchEvent events)
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

FlumeAvroManager

protected FlumeAvroManager(String name,
                           String shortName,
                           Agent[] agents,
                           int batchSize,
                           int delayMillis,
                           int retries,
                           int connectTimeout,
                           int requestTimeout)

Constructor

Parameters:

name - The unique name of this 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.

connectTimeout - The connection timeout in ms.

requestTimeout - The request timeout in ms.

Method Detail

getManager

public static FlumeAvroManager getManager(String name,
                                          Agent[] agents,
                                          int batchSize,
                                          int delayMillis,
                                          int retries,
                                          int connectTimeoutMillis,
                                          int requestTimeoutMillis)

Returns a FlumeAvroManager.

Parameters:

name - The name of the manager.

agents - The agents to use.

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

delayMillis - The number of milliseconds to wait before sending an incomplete batch.

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

connectTimeoutMillis - The connection timeout in ms.

requestTimeoutMillis - The request timeout in ms.

Returns:

A FlumeAvroManager.

getAgents

public Agent[] getAgents()

Returns the agents.

Returns:

The agent array.

getCurrent

public int getCurrent()

Returns the index of the current agent.

Returns:

The index for the current agent.

getRetries

public int getRetries()

getConnectTimeoutMillis

public int getConnectTimeoutMillis()

getRequestTimeoutMillis

public int getRequestTimeoutMillis()

getBatchSize

public int getBatchSize()

getDelayMillis

public int getDelayMillis()

send

public void send(BatchEvent events)

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