public final class VmPipeConnector extends AbstractIoConnector
IoHandler
s which is bound on the specified
VmPipeAddress
.AbstractIoService.ServiceOperationFuture
disposalLock
Constructor and Description |
---|
VmPipeConnector()
Creates a new instance.
|
VmPipeConnector(java.util.concurrent.Executor executor)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
connect0(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
protected void |
dispose0()
Implement this method to release any acquired resources.
|
VmPipeSessionConfig |
getSessionConfig()
Returns the default configuration of the new
IoSession s
created by this service. |
TransportMetadata |
getTransportMetadata()
Returns the
TransportMetadata that this service runs on. |
connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultRemoteAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultRemoteAddress, toString
addListener, broadcast, dispose, dispose, executeWorker, executeWorker, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
public VmPipeConnector()
public VmPipeConnector(java.util.concurrent.Executor executor)
public TransportMetadata getTransportMetadata()
IoService
TransportMetadata
that this service runs on.public VmPipeSessionConfig getSessionConfig()
AbstractIoService
IoSession
s
created by this service.getSessionConfig
in interface IoService
getSessionConfig
in class AbstractIoService
protected ConnectFuture connect0(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
AbstractIoConnector
connect0
in class AbstractIoConnector
localAddress
- null if no local address is specifiedprotected void dispose0() throws java.lang.Exception
AbstractIoService
AbstractIoService.dispose()
.dispose0
in class AbstractIoService
java.lang.Exception
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.