Package dev.getelements.elements.rt

Interface AsyncConnectionService<ContextT,SocketT>

All Known Implementing Classes:

JeroMQAsyncConnectionService, SharedAsyncConnectionService

public interface AsyncConnectionService<ContextT,SocketT>

A system-wide service to house AsyncConnection instances. Each instance of AsyncConnection is managed internally and callbacks issued on a background thread dedicated to that as well as other Connection instances.

Method Summary

Modifier and Type	Method	Description
default AsyncConnectionPool<ContextT,SocketT>	allocatePool(int minConnections, int maxConnections, Function<ContextT,SocketT> socketSupplier)	Allocates an instance of AsyncConnectionPool.
AsyncConnectionPool<ContextT,SocketT>	allocatePool(String name, int minConnections, int maxConnections, Function<ContextT,SocketT> socketSupplier)	Allocates an instance of AsyncConnectionPool.
default AsyncConnectionGroup.Builder<ContextT,SocketT>	group()	Creates an anonymous group.
AsyncConnectionGroup.Builder<ContextT,SocketT>	group(String name)	Returns a AsyncConnectionGroup.Builder which can be used to build an instance of AsyncConnectionGroup for managing closely related AsyncConnection instances.
void	start()	Starts the AsyncConnectionService<ContextT,SocketT>.
void	stop()	Stops the AsyncConnectionService<ContextT,SocketT>.

Method Details

start

void start()

Starts the AsyncConnectionService<ContextT,SocketT>.

stop

void stop()

Stops the AsyncConnectionService<ContextT,SocketT>.

group

default AsyncConnectionGroup.Builder<ContextT,SocketT> group()

Creates an anonymous group.

Returns:

the AsyncConnectionGroup.Builder<ContextT,SocketT>

group

AsyncConnectionGroup.Builder<ContextT,SocketT> group(String name)

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

Parameters:

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

Returns:

the AsyncConnectionGroup.Builder

allocatePool

default AsyncConnectionPool<ContextT,SocketT> allocatePool(int minConnections,
 int maxConnections,
 Function<ContextT,SocketT> socketSupplier)

Allocates an instance of AsyncConnectionPool.

Parameters:

minConnections -

maxConnections -

socketSupplier -

Returns:

allocatePool

AsyncConnectionPool<ContextT,SocketT> allocatePool(String name,
 int minConnections,
 int maxConnections,
 Function<ContextT,SocketT> socketSupplier)

Allocates an instance of AsyncConnectionPool.

Parameters:

name -

minConnections -

maxConnections -

socketSupplier -

Returns: