Package org.nuxeo.log4j

Class NuxeoStreamAppender

java.lang.Object

org.apache.logging.log4j.core.AbstractLifeCycle

org.apache.logging.log4j.core.filter.AbstractFilterable

org.apache.logging.log4j.core.appender.AbstractAppender

org.nuxeo.log4j.NuxeoStreamAppender

All Implemented Interfaces:

org.apache.logging.log4j.core.Appender, org.apache.logging.log4j.core.filter.Filterable, org.apache.logging.log4j.core.impl.LocationAware, org.apache.logging.log4j.core.LifeCycle, org.apache.logging.log4j.core.LifeCycle2

@Plugin(name="NuxeoStreamAppender",
        category="Core",
        elementType="appender")
public class NuxeoStreamAppender
extends org.apache.logging.log4j.core.appender.AbstractAppender

A Log4j appender that writes to a Nuxeo Stream using Avro encoded event.

Since:

2023.7

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NuxeoStreamAppender.Builder<B extends NuxeoStreamAppender.Builder<B>>

Nested classes/interfaces inherited from interface org.apache.logging.log4j.core.LifeCycle

org.apache.logging.log4j.core.LifeCycle.State

Field Summary

Fields

Modifier and Type	Field	Description
static final Codec<NuxeoLogEvent>	AVRO_CODEC
protected static final String	BOOTSTRAP_AUTODETECT_VALUE
protected static final String	BOOTSTRAP_PROP
protected final String	nodeId

Fields inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

DEFAULT_STOP_TIMEOUT, DEFAULT_STOP_TIMEUNIT, LOGGER

Fields inherited from interface org.apache.logging.log4j.core.Appender

ELEMENT_TYPE, EMPTY_ARRAY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NuxeoStreamAppender(String name, org.apache.logging.log4j.core.Filter filter, org.apache.logging.log4j.core.Layout<? extends Serializable> layout, boolean ignoreExceptions, org.apache.logging.log4j.core.config.Property[] properties, String nodeId, String prefix, String streamName, int partitions)

Method Summary

Modifier and Type	Method	Description
void	append(org.apache.logging.log4j.core.LogEvent event)
static <B extends NuxeoStreamAppender.Builder<B>> B	newBuilder()
boolean	stop(long timeout, TimeUnit timeUnit)

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

error, error, error, getHandler, getLayout, getName, ignoreExceptions, parseInt, requiresLocation, setHandler, toSerializable, toString

Methods inherited from class org.apache.logging.log4j.core.filter.AbstractFilterable

addFilter, getFilter, getPropertyArray, hasFilter, isFiltered, removeFilter, start, stop

Methods inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

equalsImpl, getState, getStatusLogger, hashCodeImpl, initialize, isInitialized, isStarted, isStarting, isStopped, isStopping, setStarted, setStarting, setState, setStopped, setStopping, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.logging.log4j.core.LifeCycle

getState, initialize, isStarted, isStopped, start, stop

Field Details

nodeId

protected final String nodeId

BOOTSTRAP_PROP

protected static final String BOOTSTRAP_PROP

See Also:

• Constant Field Values

BOOTSTRAP_AUTODETECT_VALUE

protected static final String BOOTSTRAP_AUTODETECT_VALUE

See Also:

• Constant Field Values

AVRO_CODEC

public static final Codec<NuxeoLogEvent> AVRO_CODEC

Constructor Details

NuxeoStreamAppender

protected NuxeoStreamAppender(String name,
 org.apache.logging.log4j.core.Filter filter,
 org.apache.logging.log4j.core.Layout<? extends Serializable> layout,
 boolean ignoreExceptions,
 org.apache.logging.log4j.core.config.Property[] properties,
 String nodeId,
 String prefix,
 String streamName,
 int partitions)

Method Details

newBuilder

@PluginBuilderFactory
public static <B extends NuxeoStreamAppender.Builder<B>>
B newBuilder()

stop

public boolean stop(long timeout,
 TimeUnit timeUnit)

Specified by:

stop in interface org.apache.logging.log4j.core.LifeCycle2

Overrides:

stop in class org.apache.logging.log4j.core.filter.AbstractFilterable

append

public void append(org.apache.logging.log4j.core.LogEvent event)