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
  • Field Details

    • SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK

      public static final String SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK
      System property to enable shutdown hook.
      See Also:
    • SYS_PROPERTY_IO_THREADS

      public static final String SYS_PROPERTY_IO_THREADS
      System property to control JeroMQ I/O thread count.
      See Also:
  • 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.
    • 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()