Class JeroMqManager

  • All Implemented Interfaces:
    java.lang.AutoCloseable

    public class JeroMqManager
    extends AbstractManager
    Manager for publishing messages via JeroMq.
    Since:
    2.6
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static org.zeromq.ZMQ.Context getContext()  
      static JeroMqManager getJeroMqManager​(java.lang.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, java.util.List<java.lang.String> endpoints)  
      protected boolean releaseSub​(long timeout, java.util.concurrent.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 java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK

        public static final java.lang.String SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK
        System property to enable shutdown hook.
        See Also:
        Constant Field Values
      • SYS_PROPERTY_IO_THREADS

        public static final java.lang.String SYS_PROPERTY_IO_THREADS
        System property to control JeroMQ I/O thread count.
        See Also:
        Constant Field Values
    • Method Detail

      • send

        public boolean send​(byte[] data)
      • releaseSub

        protected boolean releaseSub​(long timeout,
                                     java.util.concurrent.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.
      • getJeroMqManager

        public static JeroMqManager getJeroMqManager​(java.lang.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,
                                                     java.util.List<java.lang.String> endpoints)
      • getContext

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