@Plugin(name="RabbitMQ",
category="Core",
elementType="appender",
printObject=true)
public class AmqpAppender
extends org.apache.logging.log4j.core.appender.AbstractAppender
Modifier and Type | Class and Description |
---|---|
protected static class |
AmqpAppender.AmqpManager |
protected static class |
AmqpAppender.Event
Helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.
|
protected class |
AmqpAppender.EventSender
Helper class to actually send LoggingEvents asynchronously.
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
APPLICATION_ID
Key name for the application id (if there is one set via the appender config) in the message properties.
|
static java.lang.String |
CATEGORY_LEVEL
Key name for the logger level name in the message properties
|
static java.lang.String |
CATEGORY_NAME
Key name for the logger category name in the message properties
|
static java.lang.String |
THREAD_NAME
Key name for the thread name in the message properties.
|
Constructor and Description |
---|
AmqpAppender(java.lang.String name,
org.apache.logging.log4j.core.Filter filter,
org.apache.logging.log4j.core.Layout<? extends java.io.Serializable> layout,
boolean ignoreExceptions,
AmqpAppender.AmqpManager manager) |
Modifier and Type | Method and Description |
---|---|
void |
append(org.apache.logging.log4j.core.LogEvent event) |
static AmqpAppender |
createAppender(org.apache.logging.log4j.core.config.Configuration configuration,
java.lang.String name,
org.apache.logging.log4j.core.Layout<? extends java.io.Serializable> layout,
org.apache.logging.log4j.core.Filter filter,
boolean ignoreExceptions,
java.lang.String host,
int port,
java.lang.String addresses,
java.lang.String user,
java.lang.String password,
java.lang.String virtualHost,
int senderPoolSize,
int maxSenderRetries,
java.lang.String applicationId,
java.lang.String routingKeyPattern,
boolean generateId,
java.lang.String deliveryMode,
java.lang.String exchange,
java.lang.String exchangeType,
boolean declareExchange,
boolean durable,
boolean autoDelete,
java.lang.String contentType,
java.lang.String contentEncoding,
java.lang.String clientConnectionProperties,
boolean async,
java.lang.String charset) |
int |
getQueuedEventCount()
Return the number of events waiting to be sent.
|
protected Message |
postProcessMessageBeforeSend(Message message,
AmqpAppender.Event event)
Subclasses may modify the final message before sending.
|
protected boolean |
stop(long timeout,
java.util.concurrent.TimeUnit timeUnit,
boolean changeLifeCycleState) |
error, error, error, getHandler, getLayout, getName, ignoreExceptions, parseInt, setHandler, toString
addFilter, getFilter, hasFilter, isFiltered, removeFilter, start, stop
equalsImpl, getState, hashCodeImpl, initialize, isInitialized, isStarted, isStarting, isStopped, isStopping, setStarted, setStarting, setState, setStopped, setStopping, stop, stop
public static final java.lang.String APPLICATION_ID
public static final java.lang.String CATEGORY_NAME
public static final java.lang.String CATEGORY_LEVEL
public static final java.lang.String THREAD_NAME
public AmqpAppender(java.lang.String name, org.apache.logging.log4j.core.Filter filter, org.apache.logging.log4j.core.Layout<? extends java.io.Serializable> layout, boolean ignoreExceptions, AmqpAppender.AmqpManager manager)
@PluginFactory public static AmqpAppender createAppender(@PluginConfiguration org.apache.logging.log4j.core.config.Configuration configuration, @PluginAttribute(value="name") java.lang.String name, @PluginElement(value="Layout") org.apache.logging.log4j.core.Layout<? extends java.io.Serializable> layout, @PluginElement(value="Filter") org.apache.logging.log4j.core.Filter filter, @PluginAttribute(value="ignoreExceptions") boolean ignoreExceptions, @PluginAttribute(value="host") java.lang.String host, @PluginAttribute(value="port") int port, @PluginAttribute(value="addresses") java.lang.String addresses, @PluginAttribute(value="user") java.lang.String user, @PluginAttribute(value="password") java.lang.String password, @PluginAttribute(value="virtualHost") java.lang.String virtualHost, @PluginAttribute(value="senderPoolSize") int senderPoolSize, @PluginAttribute(value="maxSenderRetries") int maxSenderRetries, @PluginAttribute(value="applicationId") java.lang.String applicationId, @PluginAttribute(value="routingKeyPattern") java.lang.String routingKeyPattern, @PluginAttribute(value="generateId") boolean generateId, @PluginAttribute(value="deliveryMode") java.lang.String deliveryMode, @PluginAttribute(value="exchange") java.lang.String exchange, @PluginAttribute(value="exchangeType") java.lang.String exchangeType, @PluginAttribute(value="declareExchange") boolean declareExchange, @PluginAttribute(value="durable") boolean durable, @PluginAttribute(value="autoDelete") boolean autoDelete, @PluginAttribute(value="contentType") java.lang.String contentType, @PluginAttribute(value="contentEncoding") java.lang.String contentEncoding, @PluginAttribute(value="clientConnectionProperties") java.lang.String clientConnectionProperties, @PluginAttribute(value="async") boolean async, @PluginAttribute(value="charset") java.lang.String charset)
public void append(org.apache.logging.log4j.core.LogEvent event)
protected Message postProcessMessageBeforeSend(Message message, AmqpAppender.Event event)
message
- The message.event
- The event.protected boolean stop(long timeout, java.util.concurrent.TimeUnit timeUnit, boolean changeLifeCycleState)
stop
in class org.apache.logging.log4j.core.filter.AbstractFilterable
public int getQueuedEventCount()