Package dev.getelements.elements.rt.jeromq

Class JeroMQAsyncConnectionService

java.lang.Object

dev.getelements.elements.rt.jeromq.JeroMQAsyncConnectionService

All Implemented Interfaces:

AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

public class JeroMQAsyncConnectionService
extends Object
implements AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ASYNC_CONNECTION_IO_THREADS

Constructor Summary

Constructors

Constructor	Description
JeroMQAsyncConnectionService()

Method Summary

Modifier and Type	Method	Description
AsyncConnectionPool<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>	allocatePool(String name, int minConnections, int maxConnections, Function<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> socketSupplier)	Allocates an instance of AsyncConnectionPool.
int	getThreadPoolSize()
org.zeromq.ZContext	getzContext()
AsyncConnectionGroup.Builder<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>	group(String name)	Returns a AsyncConnectionGroup.Builder which can be used to build an instance of AsyncConnectionGroup for managing closely related AsyncConnection instances.
void	setThreadPoolSize(int threadPoolSize)
void	setzContext(org.zeromq.ZContext zContext)
void	start()	Starts the AsyncConnectionService<ContextT,SocketT>.
void	stop()	Stops the AsyncConnectionService<ContextT,SocketT>.

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.getelements.elements.rt.AsyncConnectionService

allocatePool, group

Field Details

ASYNC_CONNECTION_IO_THREADS

public static final String ASYNC_CONNECTION_IO_THREADS

See Also:

• Constant Field Values

Constructor Details

JeroMQAsyncConnectionService

public JeroMQAsyncConnectionService()

Method Details

start

public void start()

Description copied from interface: AsyncConnectionService

Starts the AsyncConnectionService<ContextT,SocketT>.

Specified by:

start in interface AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

stop

public void stop()

Description copied from interface: AsyncConnectionService

Stops the AsyncConnectionService<ContextT,SocketT>.

Specified by:

stop in interface AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

group

public AsyncConnectionGroup.Builder<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> group(String name)

Description copied from interface: AsyncConnectionService

Returns a AsyncConnectionGroup.Builder which can be used to build an instance of AsyncConnectionGroup for managing closely related AsyncConnection instances.

Specified by:

group in interface AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Parameters:

name - the name of the pool (used for logging and debugging)

Returns:

the AsyncConnectionGroup.Builder

allocatePool

public AsyncConnectionPool<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> allocatePool(String name,
 int minConnections,
 int maxConnections,
 Function<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> socketSupplier)

Description copied from interface: AsyncConnectionService

Allocates an instance of AsyncConnectionPool.

Specified by:

allocatePool in interface AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket>

Parameters:

name -

minConnections -

maxConnections -

socketSupplier -

Returns:

getzContext

public org.zeromq.ZContext getzContext()

setzContext

@Inject
public void setzContext(org.zeromq.ZContext zContext)

getThreadPoolSize

public int getThreadPoolSize()

setThreadPoolSize

@Inject
public void setThreadPoolSize(@Named("dev.getelements.elements.rt.jeromq.async.connection.service.io.threads")
 int threadPoolSize)