it.agilelab.log4j

Class FluentdAsyncJsonAppenderSink

java.lang.Object

it.agilelab.log4j.FluentdAsyncJsonAppenderSink

All Implemented Interfaces:

AsyncJsonAppenderSink, Configurable

public class FluentdAsyncJsonAppenderSink
extends Object
implements AsyncJsonAppenderSink

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTION_REQUEST_TIMEOUT
static String	CONNECTION_TIMEOUT
static String	FAILURE_STRATEGY
static String	HOST_OPTION
static String	MAX_CONNECTIONS_PER_ROUTE
static String	MAX_CONNECTIONS_TOTAL_OPTION
static String	SOCKET_TIMEOUT
static String	TAG_OPTION
static String	TRANSFER_DEADLINE

Constructor Summary

Constructors

Constructor and Description
FluentdAsyncJsonAppenderSink()
FluentdAsyncJsonAppenderSink(URI host, String tag)

Method Summary

Modifier and Type	Method and Description
void	configure(Configuration option)
void	dropped(long dropped)
void	sink(List<Json> data)

Methods inherited from class java.lang.Object

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

Field Detail

HOST_OPTION

public static final String HOST_OPTION

See Also:

Constant Field Values

TAG_OPTION

public static final String TAG_OPTION

See Also:

Constant Field Values

MAX_CONNECTIONS_TOTAL_OPTION

public static final String MAX_CONNECTIONS_TOTAL_OPTION

See Also:

Constant Field Values

MAX_CONNECTIONS_PER_ROUTE

public static final String MAX_CONNECTIONS_PER_ROUTE

See Also:

Constant Field Values

CONNECTION_REQUEST_TIMEOUT

public static final String CONNECTION_REQUEST_TIMEOUT

See Also:

Constant Field Values

CONNECTION_TIMEOUT

public static final String CONNECTION_TIMEOUT

See Also:

Constant Field Values

SOCKET_TIMEOUT

public static final String SOCKET_TIMEOUT

See Also:

Constant Field Values

TRANSFER_DEADLINE

public static final String TRANSFER_DEADLINE

See Also:

Constant Field Values

FAILURE_STRATEGY

public static final String FAILURE_STRATEGY

See Also:

Constant Field Values

Constructor Detail

FluentdAsyncJsonAppenderSink

public FluentdAsyncJsonAppenderSink(URI host,
                                    String tag)

FluentdAsyncJsonAppenderSink

public FluentdAsyncJsonAppenderSink()

Method Detail

sink

public void sink(List<Json> data)

Specified by:

sink in interface AsyncJsonAppenderSink

dropped

public void dropped(long dropped)

Specified by:

dropped in interface AsyncJsonAppenderSink

configure

public void configure(Configuration option)

Specified by:

configure in interface Configurable