public class TcpCommunicationProtocol extends Object implements CommunicationProtocolSource, CommunicationProtocol
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAXIMUM_IDLE_TIME
Default time before an idle
Connection is closed. |
static String |
PROPERTY_MAXIMUM_IDLE_TIME
Property to obtain the maximum idle time before the
Connection is
closed. |
Constructor and Description |
---|
TcpCommunicationProtocol() |
Modifier and Type | Method and Description |
---|---|
CommunicationProtocol |
createCommunicationProtocol(AbstractAsyncManagedObjectSource.MetaDataContext<None,Indexed> configurationContext,
CommunicationProtocolContext protocolContext)
Creates the
CommunicationProtocol . |
TcpConnectionHandler |
createConnectionHandler(Connection connection)
Creates a
ConnectionHandler for a new Connection . |
void |
loadSpecification(AbstractAsyncManagedObjectSource.SpecificationContext context)
Loads any specifications for this communication protocol.
|
void |
serviceConnection(TcpConnectionHandler connectionHandler)
Triggers a
ProcessState to service the Connection . |
void |
setManagedObjectExecuteContext(ManagedObjectExecuteContext<Indexed> executeContext)
Provides the
CommunicationProtocol the
ManagedObjectExecuteContext to enable it to invoke
ProcessState instances to process input. |
public static final String PROPERTY_MAXIMUM_IDLE_TIME
Connection
is
closed.public static final int DEFAULT_MAXIMUM_IDLE_TIME
Connection
is closed.public void serviceConnection(TcpConnectionHandler connectionHandler)
ProcessState
to service the Connection
.connectionHandler
- TcpConnectionHandler
for the ConnectException
.public void loadSpecification(AbstractAsyncManagedObjectSource.SpecificationContext context)
CommunicationProtocolSource
loadSpecification
in interface CommunicationProtocolSource
context
- AbstractAsyncManagedObjectSource.SpecificationContext
.public CommunicationProtocol createCommunicationProtocol(AbstractAsyncManagedObjectSource.MetaDataContext<None,Indexed> configurationContext, CommunicationProtocolContext protocolContext) throws Exception
CommunicationProtocolSource
CommunicationProtocol
.createCommunicationProtocol
in interface CommunicationProtocolSource
configurationContext
- AbstractAsyncManagedObjectSource.MetaDataContext
.protocolContext
- CommunicationProtocolSource
.CommunicationProtocol
.Exception
- If fails to create the CommunicationProtocol
.public void setManagedObjectExecuteContext(ManagedObjectExecuteContext<Indexed> executeContext)
CommunicationProtocol
CommunicationProtocol
the
ManagedObjectExecuteContext
to enable it to invoke
ProcessState
instances to process input.setManagedObjectExecuteContext
in interface CommunicationProtocol
executeContext
- ManagedObjectExecuteContext
.public TcpConnectionHandler createConnectionHandler(Connection connection)
CommunicationProtocol
ConnectionHandler
for a new Connection
.createConnectionHandler
in interface CommunicationProtocol
connection
- A new Connection
requiring handling.ConnectionHandler
to handle the new Connection
.Copyright © 2005–2016. All rights reserved.