public class SocketConnection extends AbstractConnection<ISocketConnectionAddress>
Modifier and Type | Field and Description |
---|---|
static String |
CONNECTION_ADDRESS_DEPENDENCY |
static String |
CONNECTION_DEPENDENCY |
address, COMPONENT_ID, controller, DEFAULT_LINE_END, eventBus, log
Constructor and Description |
---|
SocketConnection(ComponentDependencies dependencies,
IComponentBus bus,
IAgentLogger logger) |
SocketConnection(ISocketConnectionAddress address,
ComponentDependencies dependencies,
IComponentBus bus,
IAgentLogger logger) |
Modifier and Type | Method and Description |
---|---|
protected Reader |
getConnectionReader()
This should return plain reader for the current connection.
|
protected Writer |
getConnectionWriter()
This should return plain writer for the current connection.
|
String |
toString() |
protected void |
unsyncClose()
Inner unsynchronized implementation of the close(), should close the connection
to the remote side without throwing any exception.
|
protected void |
unsyncConnect(ISocketConnectionAddress address)
Inner implementation of connect, unsynchronized, this is called from
connect(IConnectionDescriptor).
|
getAddress, getComponentId, getLog, getMessageEnd, getReader, getWriter, setAddress, setLogMessages
public static final String CONNECTION_DEPENDENCY
public static final String CONNECTION_ADDRESS_DEPENDENCY
@Inject public SocketConnection(ISocketConnectionAddress address, ComponentDependencies dependencies, IComponentBus bus, IAgentLogger logger)
public SocketConnection(ComponentDependencies dependencies, IComponentBus bus, IAgentLogger logger)
protected Reader getConnectionReader() throws ConnectionException
AbstractConnection
getConnectionReader
in class AbstractConnection<ISocketConnectionAddress>
ConnectionException
protected Writer getConnectionWriter() throws ConnectionException
AbstractConnection
getConnectionWriter
in class AbstractConnection<ISocketConnectionAddress>
ConnectionException
protected void unsyncClose()
AbstractConnection
unsyncClose
in class AbstractConnection<ISocketConnectionAddress>
protected void unsyncConnect(ISocketConnectionAddress address) throws ConnectionException
AbstractConnection
unsyncConnect
in class AbstractConnection<ISocketConnectionAddress>
ConnectionException
public String toString()
toString
in class AbstractConnection<ISocketConnectionAddress>
Copyright © 2012 AMIS research group, Faculty of Mathematics and Physics, Charles University in Prague, Czech Republic. All Rights Reserved.