public class VmPipeConnector extends BaseSessionManager implements ProtocolConnector
ProtocolProvider
s which is bound on the specified
VmPipeAddress
.exceptionMonitor
Constructor and Description |
---|
VmPipeConnector()
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
connect(java.net.SocketAddress address,
int timeout,
ProtocolProvider protocolProvider)
Connects to the specified
address with timeout. |
ProtocolSession |
connect(java.net.SocketAddress address,
ProtocolProvider protocolProvider)
Connects to the specified
address . |
ProtocolSession |
connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
int timeout,
ProtocolProvider protocolProvider)
Connects to the specified
address with timeout. |
ProtocolSession |
connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
ProtocolProvider protocolProvider)
Connects to the specified
address . |
ProtocolFilterChain |
getFilterChain()
Returns the filter chain that filters all events which is related
with sessions this manager manages.
|
getExceptionMonitor, setExceptionMonitor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getExceptionMonitor, setExceptionMonitor
public ProtocolFilterChain getFilterChain()
ProtocolSessionManager
getFilterChain
in interface ProtocolSessionManager
public ProtocolSession connect(java.net.SocketAddress address, ProtocolProvider protocolProvider) throws java.io.IOException
ProtocolConnector
address
. If communication starts
successfully, events are fired to the specified
protocolProvider
. This method blocks.connect
in interface ProtocolConnector
java.io.IOException
- if failed to connectpublic ProtocolSession connect(java.net.SocketAddress address, java.net.SocketAddress localAddress, ProtocolProvider protocolProvider) throws java.io.IOException
ProtocolConnector
address
. If communication starts
successfully, events are fired to the specified
protocolProvider
. This method blocks.connect
in interface ProtocolConnector
localAddress
- the local address the channel is bound tojava.io.IOException
- if failed to connectpublic ProtocolSession connect(java.net.SocketAddress address, int timeout, ProtocolProvider protocolProvider) throws java.io.IOException
ProtocolConnector
address
with timeout. If
communication starts successfully, events are fired to the specified
protocolProvider
. This method blocks.connect
in interface ProtocolConnector
java.io.IOException
- if failed to connectpublic ProtocolSession connect(java.net.SocketAddress address, java.net.SocketAddress localAddress, int timeout, ProtocolProvider protocolProvider) throws java.io.IOException
ProtocolConnector
address
with timeout. If
communication starts successfully, events are fired to the specified
protocolProvider
. This method blocks.connect
in interface ProtocolConnector
localAddress
- the local address the channel is bound tojava.io.IOException
- if failed to connect