org.zeromq.jzmq.poll

Class PollerImpl

java.lang.Object

org.zeromq.jzmq.poll.PollerImpl

All Implemented Interfaces:

Poller

public class PollerImpl
extends Object
implements Poller

Constructor Summary

Constructors

Constructor and Description
PollerImpl(ManagedContext context, Map<Pollable,PollListener> pollableMap)

Method Summary

Modifier and Type	Method and Description
boolean	disable(SelectableChannel channel) Disable a channel in the poller, preventing it from waking up the thread when messages are received on it.
boolean	disable(Socket socket) Disable a socket in the poller, preventing it from waking up the thread when messages are received on it.
int	enable(SelectableChannel channel) Enable a channel in the poller after it has been disabled.
int	enable(Socket socket) Enable a socket in the poller after it has been disabled.
void	poll() Poll a socket indefinitely.
void	poll(long timeoutMillis) Poll a socket for a given amount of time.
int	register(Pollable pollable, PollListener listener) Register a new poll item.
boolean	unregister(SelectableChannel channel) Unregister a channel from the poller.
boolean	unregister(Socket socket) Unregister a socket from the poller.

Methods inherited from class java.lang.Object

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

Constructor Detail

PollerImpl

public PollerImpl(ManagedContext context,
                  Map<Pollable,PollListener> pollableMap)

Method Detail

poll

public void poll(long timeoutMillis)

Description copied from interface: Poller

Poll a socket for a given amount of time.

Specified by:

poll in interface Poller

Parameters:

timeoutMillis - The number of milliseconds to wait before returning

poll

public void poll()

Description copied from interface: Poller

Poll a socket indefinitely.

Specified by:

poll in interface Poller

enable

public int enable(Socket socket)

Description copied from interface: Poller

Enable a socket in the poller after it has been disabled.

Specified by:

enable in interface Poller

Parameters:

socket - The socket registered with the poller to be enabled

Returns:

The new index of the socket in the poller, for reference

disable

public boolean disable(Socket socket)

Description copied from interface: Poller

Disable a socket in the poller, preventing it from waking up the thread when messages are received on it.

Specified by:

disable in interface Poller

Parameters:

socket - The socket registered with the poller to be disabled

Returns:

true if the socket was disabled, false otherwise

enable

public int enable(SelectableChannel channel)

Description copied from interface: Poller

Enable a channel in the poller after it has been disabled.

Specified by:

enable in interface Poller

Parameters:

channel - The channel registered with the poller to be enabled

Returns:

The new index of the socket in the poller, for reference

disable

public boolean disable(SelectableChannel channel)

Description copied from interface: Poller

Disable a channel in the poller, preventing it from waking up the thread when messages are received on it.

Specified by:

disable in interface Poller

Parameters:

channel - The channel registered with the poller to be disabled

Returns:

true if the socket was disabled, false otherwise

register

public int register(Pollable pollable,
                    PollListener listener)

Description copied from interface: Poller

Register a new poll item.

Specified by:

register in interface Poller

Parameters:

pollable - The pollable containing the socket and polling options

listener - The listener that handles events for the given pollable

Returns:

The new index of the socket in the poller, for reference

unregister

public boolean unregister(Socket socket)

Description copied from interface: Poller

Unregister a socket from the poller.

Specified by:

unregister in interface Poller

Parameters:

socket - The socket registered with the poller to be unregistered

Returns:

true if the socket was unregistered, false otherwise

unregister

public boolean unregister(SelectableChannel channel)

Description copied from interface: Poller

Unregister a channel from the poller.

Specified by:

unregister in interface Poller

Parameters:

channel - The channel registered with the poller to be unregistered

Returns:

true if the socket was disabled, false otherwise