Package org.zeromq

Class ZBeacon


  • public class ZBeacon
    extends java.lang.Object
    • Field Detail

      • DEFAULT_BROADCAST_INTERVAL

        public static final long DEFAULT_BROADCAST_INTERVAL
        See Also:
        Constant Field Values
      • DEFAULT_BROADCAST_HOST

        public static final java.lang.String DEFAULT_BROADCAST_HOST
        See Also:
        Constant Field Values
      • DEFAULT_BROADCAST_ADDRESS

        private static final byte[] DEFAULT_BROADCAST_ADDRESS
      • prefix

        private final java.util.concurrent.atomic.AtomicReference<byte[]> prefix
      • beacon

        private final java.util.concurrent.atomic.AtomicReference<byte[]> beacon
      • broadcastInterval

        private final java.util.concurrent.atomic.AtomicLong broadcastInterval
      • listener

        private final java.util.concurrent.atomic.AtomicReference<ZBeacon.Listener> listener
      • clientHandler

        private java.util.concurrent.atomic.AtomicReference<java.lang.Thread.UncaughtExceptionHandler> clientHandler
      • serverHandler

        private java.util.concurrent.atomic.AtomicReference<java.lang.Thread.UncaughtExceptionHandler> serverHandler
    • Constructor Detail

      • ZBeacon

        public ZBeacon​(int port,
                       byte[] beacon)
      • ZBeacon

        public ZBeacon​(java.lang.String host,
                       int port,
                       byte[] beacon)
      • ZBeacon

        public ZBeacon​(java.lang.String host,
                       int port,
                       byte[] beacon,
                       boolean ignoreLocalAddress)
      • ZBeacon

        public ZBeacon​(java.lang.String host,
                       int port,
                       byte[] beacon,
                       boolean ignoreLocalAddress,
                       boolean blocking)
      • ZBeacon

        public ZBeacon​(java.lang.String broadcastAddress,
                       byte[] serverAddress,
                       int port,
                       byte[] beacon,
                       long broadcastInterval,
                       boolean ignoreLocalAddress,
                       boolean blocking)
    • Method Detail

      • setUncaughtExceptionHandlers

        public void setUncaughtExceptionHandlers​(java.lang.Thread.UncaughtExceptionHandler clientHandler,
                                                 java.lang.Thread.UncaughtExceptionHandler serverHandler)
      • startClient

        public void startClient()
      • startServer

        public void startServer()
      • start

        public void start()
      • stop

        public void stop()
                  throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • setBeacon

        public void setBeacon​(byte[] beacon)
      • getBeacon

        public byte[] getBeacon()
      • setPrefix

        public void setPrefix​(byte[] prefix)
      • getPrefix

        public byte[] getPrefix()
      • getBroadcastInterval

        public long getBroadcastInterval()
      • setBroadcastInterval

        public void setBroadcastInterval​(long broadcastInterval)