Package org.apache.logging.log4j.core.appender.mom.jeromq

Class JeroMqManager

java.lang.Object

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

org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager

All Implemented Interfaces:

AutoCloseable

public class JeroMqManager
extends AbstractManager

Manager for publishing messages via JeroMq.

Since:

2.6

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	JeroMqManager.JeroMqConfiguration
private static class	JeroMqManager.JeroMqManagerFactory

Nested classes/interfaces inherited from class org.apache.logging.log4j.core.appender.AbstractManager

AbstractManager.AbstractFactoryData

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.zeromq.ZContext	CONTEXT
private final List<String>	endpoints
private static final JeroMqManager.JeroMqManagerFactory	FACTORY
private final org.zeromq.ZMQ.Socket	publisher
private static final Cancellable	SHUTDOWN_HOOK
static final String	SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK	System property to enable shutdown hook.
static final String	SYS_PROPERTY_IO_THREADS	System property to control JeroMQ I/O thread count.

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

count, LOGGER

Constructor Summary

Constructors

Modifier	Constructor	Description
private	JeroMqManager(String name, JeroMqManager.JeroMqConfiguration config)

Method Summary

Modifier and Type	Method	Description
static org.zeromq.ZMQ.Context	getContext()
List<String>	getEndpoints()
static JeroMqManager	getJeroMqManager(String name, long affinity, long backlog, boolean delayAttachOnConnect, byte[] identity, boolean ipv4Only, long linger, long maxMsgSize, long rcvHwm, long receiveBufferSize, int receiveTimeOut, long reconnectIVL, long reconnectIVLMax, long sendBufferSize, int sendTimeOut, long sndHwm, int tcpKeepAlive, long tcpKeepAliveCount, long tcpKeepAliveIdle, long tcpKeepAliveInterval, boolean xpubVerbose, List<String> endpoints)
(package private) org.zeromq.ZMQ.Socket	getSocket()
static org.zeromq.ZContext	getZContext()
protected boolean	releaseSub(long timeout, TimeUnit timeUnit)	May be overridden by managers to perform processing while the manager is being released and the lock is held.
boolean	send(byte[] data)

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

close, getContentFormat, getCount, getLoggerContext, getManager, getName, getStrSubstitutor, 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

Field Details

SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK

public static final String SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK

System property to enable shutdown hook.

See Also:

• Constant Field Values

SYS_PROPERTY_IO_THREADS

public static final String SYS_PROPERTY_IO_THREADS

System property to control JeroMQ I/O thread count.

See Also:

• Constant Field Values

FACTORY

private static final JeroMqManager.JeroMqManagerFactory FACTORY

CONTEXT

private static final org.zeromq.ZContext CONTEXT

SHUTDOWN_HOOK

private static final Cancellable SHUTDOWN_HOOK

publisher

private final org.zeromq.ZMQ.Socket publisher

endpoints

private final List<String> endpoints

Constructor Details

JeroMqManager

private JeroMqManager(String name,
 JeroMqManager.JeroMqConfiguration config)

Method Details

send

public boolean send(byte[] data)

releaseSub

protected boolean releaseSub(long timeout,
 TimeUnit timeUnit)

Description copied from class: AbstractManager

May be overridden by managers to perform processing while the manager is being released and the lock is held. A timeout is passed for implementors to use as they see fit.

Overrides:

releaseSub in class AbstractManager

Parameters:

timeout - timeout

timeUnit - timeout time unit

Returns:

true if all resources were closed normally, false otherwise.

getSocket

org.zeromq.ZMQ.Socket getSocket()

getEndpoints

public List<String> getEndpoints()

getJeroMqManager

public static JeroMqManager getJeroMqManager(String name,
 long affinity,
 long backlog,
 boolean delayAttachOnConnect,
 byte[] identity,
 boolean ipv4Only,
 long linger,
 long maxMsgSize,
 long rcvHwm,
 long receiveBufferSize,
 int receiveTimeOut,
 long reconnectIVL,
 long reconnectIVLMax,
 long sendBufferSize,
 int sendTimeOut,
 long sndHwm,
 int tcpKeepAlive,
 long tcpKeepAliveCount,
 long tcpKeepAliveIdle,
 long tcpKeepAliveInterval,
 boolean xpubVerbose,
 List<String> endpoints)

getContext

public static org.zeromq.ZMQ.Context getContext()

getZContext

public static org.zeromq.ZContext getZContext()