Package dev.getelements.elements.rt

Class SharedAsyncConnectionService<ContextT,SocketT>

java.lang.Object

dev.getelements.elements.rt.SharedAsyncConnectionService<ContextT,SocketT>

Type Parameters:

ContextT -

SocketT -

All Implemented Interfaces:

AsyncConnectionService<ContextT,SocketT>

public class SharedAsyncConnectionService<ContextT,SocketT>
extends Object
implements AsyncConnectionService<ContextT,SocketT>

A type of AsyncConnectionService which uses an internal reference count to ensure that the backed AsyncConnectionService is opened and closed properly. This is mainly intended for testing as production level code should share a single global-instance of AsyncConnectionService

Constructor Summary

Constructors

Constructor	Description
SharedAsyncConnectionService(AsyncConnectionService<ContextT,SocketT> delegate)

Method Summary

Modifier and Type	Method	Description
AsyncConnectionPool<ContextT,SocketT>	allocatePool(String name, int minConnections, int maxConnections, Function<ContextT,SocketT> socketSupplier)	Allocates an instance of AsyncConnectionPool.
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>.

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

Constructor Details

SharedAsyncConnectionService

@Inject
public SharedAsyncConnectionService(AsyncConnectionService<ContextT,SocketT> delegate)

Method Details

start

public void start()

Description copied from interface: AsyncConnectionService

Starts the AsyncConnectionService<ContextT,SocketT>.

Specified by:

start in interface AsyncConnectionService<ContextT,SocketT>

stop

public void stop()

Description copied from interface: AsyncConnectionService

Stops the AsyncConnectionService<ContextT,SocketT>.

Specified by:

stop in interface AsyncConnectionService<ContextT,SocketT>

group

public AsyncConnectionGroup.Builder<ContextT,SocketT> 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<ContextT,SocketT>

Parameters:

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

Returns:

the AsyncConnectionGroup.Builder

allocatePool

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

Description copied from interface: AsyncConnectionService

Allocates an instance of AsyncConnectionPool.

Specified by:

allocatePool in interface AsyncConnectionService<ContextT,SocketT>

Parameters:

name -

minConnections -

maxConnections -

socketSupplier -

Returns: