public class VmPipeAcceptor extends BaseSessionManager implements ProtocolAcceptor
ProtocolProvider
to the specified
VmPipeAddress
.exceptionMonitor
Constructor and Description |
---|
VmPipeAcceptor()
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
bind(java.net.SocketAddress address,
ProtocolProvider protocolProvider)
Binds to the specified
address and handles incoming
connections with the specified protocolProvider . |
ProtocolFilterChain |
getFilterChain()
Returns the filter chain that filters all events which is related
with sessions this manager manages.
|
ProtocolSession |
newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns a
ProtocolSession that is bound to the specified
localAddress and remoteAddress which reuses
the localAddress that is already bound by ProtocolAcceptor
via ProtocolAcceptor.bind(SocketAddress, ProtocolProvider) . |
void |
unbind(java.net.SocketAddress address)
Unbinds from the specified
address . |
getExceptionMonitor, setExceptionMonitor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getExceptionMonitor, setExceptionMonitor
public void bind(java.net.SocketAddress address, ProtocolProvider protocolProvider) throws java.io.IOException
ProtocolAcceptor
address
and handles incoming
connections with the specified protocolProvider
.bind
in interface ProtocolAcceptor
java.io.IOException
- if failed to bindpublic void unbind(java.net.SocketAddress address)
ProtocolAcceptor
address
.unbind
in interface ProtocolAcceptor
public ProtocolFilterChain getFilterChain()
ProtocolSessionManager
getFilterChain
in interface ProtocolSessionManager
public ProtocolSession newSession(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
ProtocolAcceptor
ProtocolSession
that is bound to the specified
localAddress and remoteAddress which reuses
the localAddress that is already bound by ProtocolAcceptor
via ProtocolAcceptor.bind(SocketAddress, ProtocolProvider)
.
This operation is optional. Please throw UnsupportedOperationException
if the transport type doesn't support this operation. This operation is
usually implemented for connectionless transport types.
newSession
in interface ProtocolAcceptor