net.officefloor.plugin.socket.server.impl

Class ConnectionManagerImpl

java.lang.Object

net.officefloor.frame.util.AbstractSingleTask<ConnectionManagerImpl,None,None>

net.officefloor.plugin.socket.server.impl.ConnectionManagerImpl

All Implemented Interfaces:

TaskFactory<ConnectionManagerImpl,None,None>, WorkFactory<ConnectionManagerImpl>, Task<ConnectionManagerImpl,None,None>, Work, ConnectionManager

public class ConnectionManagerImpl
extends AbstractSingleTask<ConnectionManagerImpl,None,None>
implements ConnectionManager

Manages the EstablishedConnection instances for the ServerSocketAccepter instances across the available SocketListener instances.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor and Description
ConnectionManagerImpl(long heartbeatInterval, SocketListener... socketListeners) Initiate.

Method Summary

Modifier and Type	Method and Description
void	closeSocketSelectors() Closes the Selector instances for managing the EstablishedConnection instances.
Object	doTask(TaskContext<ConnectionManagerImpl,None,None> context) Does the task.
void	manageConnection(EstablishedConnection connection) Manages the EstablishedConnection.
void	openSocketSelectors() Opens the Selector instances for managing the EstablishedConnection instances.

Methods inherited from class net.officefloor.frame.util.AbstractSingleTask

createTask, createWork, getRecycleManagedObjectParameter, registerAsRecycleTask, registerTask, registerTask, registerTask, registerWork

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionManagerImpl

public ConnectionManagerImpl(long heartbeatInterval,
                             SocketListener... socketListeners)

Initiate.

Parameters:

heartbeatInterval - Heart beat interval in milliseconds.

socketListeners - Available SocketListener instances.

Method Detail

openSocketSelectors

public void openSocketSelectors()
                         throws IOException

Description copied from interface: ConnectionManager

Opens the Selector instances for managing the EstablishedConnection instances.

Specified by:

openSocketSelectors in interface ConnectionManager

Throws:

IOException - If fails to open all the Selector instances.

manageConnection

public void manageConnection(EstablishedConnection connection)

Description copied from interface: ConnectionManager

Manages the EstablishedConnection.

Specified by:

manageConnection in interface ConnectionManager

Parameters:

connection - EstablishedConnection to be managed.

closeSocketSelectors

public void closeSocketSelectors()
                          throws IOException

Description copied from interface: ConnectionManager

Closes the Selector instances for managing the EstablishedConnection instances.

Specified by:

closeSocketSelectors in interface ConnectionManager

Throws:

IOException - If fails to close Selector instances.

doTask

public Object doTask(TaskContext<ConnectionManagerImpl,None,None> context)
              throws Throwable

Description copied from interface: Task

Does the task.

Specified by:

doTask in interface Task<ConnectionManagerImpl,None,None>

Parameters:

context - TaskContext for the Task.

Returns:

Parameter for the next Task. This allows stringing Task instances together into a JobSequence.

Throws:

Throwable - Indicating failure of the Task.