Package dev.getelements.elements.rt.jeromq

Class JeroMQAsyncConnectionGroup

java.lang.Object

dev.getelements.elements.rt.jeromq.JeroMQAsyncConnectionGroup

All Implemented Interfaces:

AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>, AutoCloseable

public class JeroMQAsyncConnectionGroup
extends Object
implements AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Nested Class Summary

Nested classes/interfaces inherited from interface dev.getelements.elements.rt.AsyncConnectionGroup

AsyncConnectionGroup.Builder<ContextT,BuilderSocketT>

Constructor Summary

Constructors

Constructor	Description
JeroMQAsyncConnectionGroup(List<AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>> connectionList, BiConsumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>,Consumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>>> signalHandler)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes all Connection instances assocaited with this AsyncConnectionGroup.
AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>	get(int index)	Gets the AsyncConnection at the provided index.
void	signal(Consumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>> consumer)	Similar to AsyncConnection.signal(Consumer), this executes the the supplied Consumer within the thread that is servicing all of the underlying AsyncConnection instances associated with the AsyncConnectionGroup
int	size()	Returns the number of AsyncConnection instances in this AsyncConnectionGroup.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

JeroMQAsyncConnectionGroup

public JeroMQAsyncConnectionGroup(List<AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>> connectionList,
 BiConsumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>,Consumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>>> signalHandler)

Method Details

size

public int size()

Description copied from interface: AsyncConnectionGroup

Returns the number of AsyncConnection instances in this AsyncConnectionGroup.

Specified by:

size in interface AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Returns:

the size

get

public AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> get(int index)

Description copied from interface: AsyncConnectionGroup

Gets the AsyncConnection at the provided index. The AsyncConnections will be returned in the order in which AsyncConnectionGroup.Builder.connection(Function, Consumer) was invoked.

Specified by:

get in interface AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Parameters:

index - the index of the AsyncConnection

Returns:

the AsyncConnection

close

public void close()

Description copied from interface: AsyncConnectionGroup

Closes all Connection instances assocaited with this AsyncConnectionGroup. Safe to call from any thread.

Specified by:

close in interface AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Specified by:

close in interface AutoCloseable

toString

public String toString()

Overrides:

toString in class Object

signal

public void signal(Consumer<AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>> consumer)

Description copied from interface: AsyncConnectionGroup

Similar to AsyncConnection.signal(Consumer), this executes the the supplied Consumer within the thread that is servicing all of the underlying AsyncConnection instances associated with the AsyncConnectionGroup

Specified by:

signal in interface AsyncConnectionGroup<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Parameters:

consumer -