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
Manager for publishing messages via JeroMq.
- Since:
- 2.6
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.logging.log4j.core.appender.AbstractManager
AbstractManager.AbstractFactoryData
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
System property to enable shutdown hook.static final String
System property to control JeroMQ I/O thread count.Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager
count, LOGGER
-
Method Summary
Modifier and TypeMethodDescriptionstatic org.zeromq.ZMQ.Context
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) static org.zeromq.ZContext
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
-
Field Details
-
SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK
System property to enable shutdown hook.- See Also:
-
SYS_PROPERTY_IO_THREADS
System property to control JeroMQ I/O thread count.- See Also:
-
-
Method Details
-
send
public boolean send(byte[] data) -
releaseSub
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 classAbstractManager
- Parameters:
timeout
- timeouttimeUnit
- timeout time unit- Returns:
- true if all resources were closed normally, false otherwise.
-
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()
-