de.huxhorn.lilith.logback.appender

Class MultiplexSocketAppenderBase<E>

java.lang.Object

ch.qos.logback.core.spi.ContextAwareBase

ch.qos.logback.core.UnsynchronizedAppenderBase<E>

de.huxhorn.lilith.logback.appender.MultiplexSocketAppenderBase<E>

All Implemented Interfaces:

ch.qos.logback.core.Appender<E>, ch.qos.logback.core.spi.ContextAware, ch.qos.logback.core.spi.FilterAttachable<E>, ch.qos.logback.core.spi.LifeCycle

Direct Known Subclasses:

AccessMultiplexSocketAppender, ClassicJsonMultiplexSocketAppender, ClassicMultiplexSocketAppender, ClassicXmlMultiplexSocketAppender, ZeroDelimitedClassicJsonMultiplexSocketAppender, ZeroDelimitedClassicXmlMultiplexSocketAppender

public abstract class MultiplexSocketAppenderBase<E>
extends ch.qos.logback.core.UnsynchronizedAppenderBase<E>

Field Summary

Fields inherited from class ch.qos.logback.core.UnsynchronizedAppenderBase

name, started

Fields inherited from class ch.qos.logback.core.spi.ContextAwareBase

context

Constructor Summary

Constructors

Constructor and Description
MultiplexSocketAppenderBase()
MultiplexSocketAppenderBase(WriteByteStrategy writeByteStrategy)
MultiplexSocketAppenderBase(WriteByteStrategy writeByteStrategy, int queueSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	addRemoteHost(java.lang.String remoteHost)
protected void	append(E e)
protected abstract void	applicationIdentifierChanged()
java.lang.String	getApplicationIdentifier()
protected de.huxhorn.sulky.codec.Encoder<E>	getEncoder()
int	getPort()
int	getQueueSize()
int	getReconnectionDelay()
java.util.List<java.lang.String>	getRemoteHostsList()
java.lang.String	getUUID()
boolean	isCreatingUUID()
boolean	isDebug()
protected abstract void	preProcess(E e)
protected void	sendBytes(byte[] bytes)
void	setApplicationIdentifier(java.lang.String applicationIdentifier)
void	setCreatingUUID(boolean creatingUUID)
void	setDebug(boolean debug)
protected void	setEncoder(de.huxhorn.sulky.codec.Encoder<E> encoder)
void	setPort(int port)
void	setQueueSize(int queueSize)
void	setReconnectionDelay(int reconnectionDelay)
void	setRemoteHosts(java.lang.String remoteHosts) Sets the remote host list by splitting the string remoteHosts.
void	setRemoteHostsList(java.util.List<java.lang.String> remoteHostsList) Sets the list of remote hosts.
void	start() Start this appender.
void	stop() Stop this appender.
protected abstract void	uuidChanged()

Methods inherited from class ch.qos.logback.core.UnsynchronizedAppenderBase

addFilter, clearAllFilters, doAppend, getCopyOfAttachedFiltersList, getFilterChainDecision, getName, isStarted, setName, toString

Methods inherited from class ch.qos.logback.core.spi.ContextAwareBase

addError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, getDeclaredOrigin, getStatusManager, setContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.qos.logback.core.spi.ContextAware

addError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, setContext

Constructor Detail

MultiplexSocketAppenderBase

public MultiplexSocketAppenderBase()

MultiplexSocketAppenderBase

public MultiplexSocketAppenderBase(WriteByteStrategy writeByteStrategy)

MultiplexSocketAppenderBase

public MultiplexSocketAppenderBase(WriteByteStrategy writeByteStrategy,
                           int queueSize)

Method Detail

isCreatingUUID

public boolean isCreatingUUID()

setCreatingUUID

public void setCreatingUUID(boolean creatingUUID)

getUUID

public java.lang.String getUUID()

uuidChanged

protected abstract void uuidChanged()

isDebug

public boolean isDebug()

setDebug

public void setDebug(boolean debug)

getQueueSize

public int getQueueSize()

setQueueSize

public void setQueueSize(int queueSize)

getApplicationIdentifier

public java.lang.String getApplicationIdentifier()

setApplicationIdentifier

public void setApplicationIdentifier(java.lang.String applicationIdentifier)

applicationIdentifierChanged

protected abstract void applicationIdentifierChanged()

getReconnectionDelay

public int getReconnectionDelay()

setReconnectionDelay

public void setReconnectionDelay(int reconnectionDelay)

getPort

public int getPort()

setPort

public void setPort(int port)

getRemoteHostsList

public java.util.List<java.lang.String> getRemoteHostsList()

setRemoteHosts

public void setRemoteHosts(java.lang.String remoteHosts)

Sets the remote host list by splitting the string remoteHosts. It is expected to be comma-separated.

Parameters:

remoteHosts - comma-seperated list of hosts.

setRemoteHostsList

public void setRemoteHostsList(java.util.List<java.lang.String> remoteHostsList)

Sets the list of remote hosts.

This method should also be called setRemoteHosts but Joran explodes if it has the same name as the String version.

Parameters:

remoteHostsList - the list of remote hosts.

addRemoteHost

public void addRemoteHost(java.lang.String remoteHost)

start

public void start()

Start this appender.

Specified by:

start in interface ch.qos.logback.core.spi.LifeCycle

Overrides:

start in class ch.qos.logback.core.UnsynchronizedAppenderBase<E>

stop

public void stop()

Stop this appender.

This will mark the appender as closed and calls the cleanUp() method.

Specified by:

stop in interface ch.qos.logback.core.spi.LifeCycle

Overrides:

stop in class ch.qos.logback.core.UnsynchronizedAppenderBase<E>

sendBytes

protected void sendBytes(byte[] bytes)

append

protected void append(E e)

Specified by:

append in class ch.qos.logback.core.UnsynchronizedAppenderBase<E>

preProcess

protected abstract void preProcess(E e)

getEncoder

protected de.huxhorn.sulky.codec.Encoder<E> getEncoder()

setEncoder

protected void setEncoder(de.huxhorn.sulky.codec.Encoder<E> encoder)