Package org.zeromq

Class ZBeacon

java.lang.Object

org.zeromq.ZBeacon

public class ZBeacon
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ZBeacon.BroadcastClient	The broadcast client periodically sends beacons via UDP to the network.
private class	ZBeacon.BroadcastServer	The broadcast server receives beacons.
static class	ZBeacon.Builder
static interface	ZBeacon.Listener	All beacons with matching prefix are passed to a listener.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicReference<byte[]>	beacon
private final ZBeacon.BroadcastClient	broadcastClient
private final AtomicLong	broadcastInterval
private final ZBeacon.BroadcastServer	broadcastServer
private AtomicReference<Thread.UncaughtExceptionHandler>	clientHandler
private static final byte[]	DEFAULT_BROADCAST_ADDRESS
static final String	DEFAULT_BROADCAST_HOST
static final long	DEFAULT_BROADCAST_INTERVAL
private final AtomicReference<ZBeacon.Listener>	listener
private final AtomicReference<byte[]>	prefix
private AtomicReference<Thread.UncaughtExceptionHandler>	serverHandler

Constructor Summary

Constructors

Constructor	Description
ZBeacon(int port, byte[] beacon)
ZBeacon(String broadcastAddress, byte[] serverAddress, int port, byte[] beacon, long broadcastInterval, boolean ignoreLocalAddress, boolean blocking)
ZBeacon(String host, int port, byte[] beacon)
ZBeacon(String host, int port, byte[] beacon, boolean ignoreLocalAddress)
ZBeacon(String host, int port, byte[] beacon, boolean ignoreLocalAddress, boolean blocking)

Method Summary

Modifier and Type	Method	Description
byte[]	getBeacon()
long	getBroadcastInterval()
ZBeacon.Listener	getListener()
byte[]	getPrefix()
void	setBeacon(byte[] beacon)
void	setBroadcastInterval(long broadcastInterval)
void	setListener(ZBeacon.Listener listener)
void	setPrefix(byte[] prefix)
void	setUncaughtExceptionHandlers(Thread.UncaughtExceptionHandler clientHandler, Thread.UncaughtExceptionHandler serverHandler)
void	start()
void	startClient()
void	startServer()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_BROADCAST_INTERVAL

public static final long DEFAULT_BROADCAST_INTERVAL

See Also:

• Constant Field Values

DEFAULT_BROADCAST_HOST

public static final String DEFAULT_BROADCAST_HOST

See Also:

• Constant Field Values

DEFAULT_BROADCAST_ADDRESS

private static final byte[] DEFAULT_BROADCAST_ADDRESS

broadcastClient

private final ZBeacon.BroadcastClient broadcastClient

broadcastServer

private final ZBeacon.BroadcastServer broadcastServer

prefix

private final AtomicReference<byte[]> prefix

beacon

private final AtomicReference<byte[]> beacon

broadcastInterval

private final AtomicLong broadcastInterval

listener

private final AtomicReference<ZBeacon.Listener> listener

clientHandler

private AtomicReference<Thread.UncaughtExceptionHandler> clientHandler

serverHandler

private AtomicReference<Thread.UncaughtExceptionHandler> serverHandler

Constructor Details

ZBeacon

public ZBeacon(int port,
 byte[] beacon)

ZBeacon

public ZBeacon(String host,
 int port,
 byte[] beacon)

ZBeacon

public ZBeacon(String host,
 int port,
 byte[] beacon,
 boolean ignoreLocalAddress)

ZBeacon

public ZBeacon(String host,
 int port,
 byte[] beacon,
 boolean ignoreLocalAddress,
 boolean blocking)

ZBeacon

public ZBeacon(String broadcastAddress,
 byte[] serverAddress,
 int port,
 byte[] beacon,
 long broadcastInterval,
 boolean ignoreLocalAddress,
 boolean blocking)

Method Details

setUncaughtExceptionHandlers

public void setUncaughtExceptionHandlers(Thread.UncaughtExceptionHandler clientHandler,
 Thread.UncaughtExceptionHandler serverHandler)

startClient

public void startClient()

startServer

public void startServer()

start

public void start()

stop

public void stop()
          throws InterruptedException

Throws:

InterruptedException

setBeacon

public void setBeacon(byte[] beacon)

getBeacon

public byte[] getBeacon()

setPrefix

public void setPrefix(byte[] prefix)

getPrefix

public byte[] getPrefix()

setListener

public void setListener(ZBeacon.Listener listener)

getListener

public ZBeacon.Listener getListener()

getBroadcastInterval

public long getBroadcastInterval()

setBroadcastInterval

public void setBroadcastInterval(long broadcastInterval)