public static class ZMQ.Poller
extends java.lang.Object
implements java.io.Closeable
Modifier and Type | Field and Description |
---|---|
private ZMQ.Context |
context |
private java.util.List<ZMQ.PollItem> |
items |
static int |
POLLERR
For standard sockets, this flag is passed through
ZMQ.poll(Selector, zmq.poll.PollItem[], long) to the underlying poll() system call
and generally means that some sort of error condition is present on the socket specified by fd. |
static int |
POLLIN
For ØMQ sockets, at least one message may be received from the socket without blocking.
|
static int |
POLLOUT
For ØMQ sockets, at least one message may be sent to the socket without blocking.
|
private java.nio.channels.Selector |
selector |
private static int |
SIZE_DEFAULT |
private static int |
SIZE_INCREMENT |
private long |
timeout |
Modifier | Constructor and Description |
---|---|
protected |
Poller(ZMQ.Context context)
Class constructor.
|
protected |
Poller(ZMQ.Context context,
int size)
Class constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
ZMQ.PollItem |
getItem(int index)
Get the PollItem associated with an index.
|
int |
getNext()
Deprecated.
use getSize instead
|
int |
getSize()
Get the current poll set size.
|
ZMQ.Socket |
getSocket(int index)
Get the socket associated with an index.
|
long |
getTimeout()
Deprecated.
Timeout handling has been moved to the poll() methods.
|
int |
poll()
Issue a poll call.
|
int |
poll(long tout)
Issue a poll call, using the specified timeout value.
|
boolean |
pollerr(int index)
Check whether the specified element in the poll set was signaled for error.
|
boolean |
pollin(int index)
Check whether the specified element in the poll set was signaled for input.
|
boolean |
pollout(int index)
Check whether the specified element in the poll set was signaled for output.
|
int |
register(java.nio.channels.SelectableChannel channel)
Register a Channel for polling on all events.
|
int |
register(java.nio.channels.SelectableChannel channel,
int events)
Register a Socket for polling on the specified events.
|
int |
register(ZMQ.PollItem item)
Register a Channel for polling on the specified events.
|
int |
register(ZMQ.Socket socket)
Register a Socket for polling on all events.
|
int |
register(ZMQ.Socket socket,
int events)
Register a Socket for polling on the specified events.
|
private int |
registerInternal(ZMQ.PollItem item)
Register a Socket for polling on the specified events.
|
void |
setTimeout(long timeout)
Deprecated.
Timeout handling has been moved to the poll() methods.
|
void |
unregister(java.nio.channels.SelectableChannel channel)
Unregister a Socket for polling on the specified events.
|
void |
unregister(ZMQ.Socket socket)
Unregister a Socket for polling on the specified events.
|
private void |
unregisterInternal(java.lang.Object socket)
Unregister a Socket for polling on the specified events.
|
public static final int POLLIN
public static final int POLLOUT
public static final int POLLERR
ZMQ.poll(Selector, zmq.poll.PollItem[], long)
to the underlying poll() system call
and generally means that some sort of error condition is present on the socket specified by fd.
ZMQ.poll(Selector, zmq.poll.PollItem[], long)
.private static final int SIZE_DEFAULT
private static final int SIZE_INCREMENT
private final java.nio.channels.Selector selector
private final ZMQ.Context context
private java.util.List<ZMQ.PollItem> items
private long timeout
protected Poller(ZMQ.Context context, int size)
context
- a 0MQ context previously created.size
- the number of Sockets this poller will contain.protected Poller(ZMQ.Context context)
context
- a 0MQ context previously created.public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public int register(ZMQ.Socket socket)
socket
- the Socket we are registering.public int register(java.nio.channels.SelectableChannel channel)
channel
- the Channel we are registering.public int register(ZMQ.Socket socket, int events)
Automatically grow the internal representation if needed.
socket
- the Socket we are registering.events
- a mask composed by XORing POLLIN, POLLOUT and POLLERR.public int register(java.nio.channels.SelectableChannel channel, int events)
Automatically grow the internal representation if needed.
channel
- the Channel we are registering.events
- a mask composed by XORing POLLIN, POLLOUT and POLLERR.public int register(ZMQ.PollItem item)
Automatically grow the internal representation if needed.
item
- the PollItem we are registering.private int registerInternal(ZMQ.PollItem item)
Automatically grow the internal representation if needed.
item
- the PollItem we are registering.public void unregister(ZMQ.Socket socket)
socket
- the Socket to be unregisteredpublic void unregister(java.nio.channels.SelectableChannel channel)
channel
- the Socket to be unregisteredprivate void unregisterInternal(java.lang.Object socket)
socket
- the Socket to be unregisteredpublic ZMQ.PollItem getItem(int index)
index
- the desired index.public ZMQ.Socket getSocket(int index)
index
- the desired index.@Deprecated public long getTimeout()
@Deprecated public void setTimeout(long timeout)
timeout
- the desired poll timeout in milliseconds.public int getSize()
@Deprecated public int getNext()
public int poll()
public int poll(long tout)
Since ZeroMQ 3.0, the timeout parameter is in milliseconds, but prior to this the unit was microseconds.
tout
- the timeout, as per zmq_poll ();
if -1, it will block indefinitely until an event
happens; if 0, it will return immediately;
otherwise, it will wait for at most that many
milliseconds/microseconds (see above).public boolean pollin(int index)
index
- of elementpublic boolean pollout(int index)
index
- of elementpublic boolean pollerr(int index)
index
- of element