public final class VmPipeConnector extends AbstractIoConnector
IoHandler
s which is bound on the specified
VmPipeAddress
.AbstractIoService.ServiceOperationFuture
disposalLock, LOGGER, sessionConfig
Constructor and Description |
---|
VmPipeConnector()
Creates a new instance.
|
VmPipeConnector(Executor executor)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
connect0(SocketAddress remoteAddress,
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() |
TransportMetadata |
getTransportMetadata() |
connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultLocalAddress, getDefaultRemoteAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultLocalAddress, 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(Executor executor)
executor
- The executor to usepublic TransportMetadata getTransportMetadata()
TransportMetadata
that this service runs on.public VmPipeSessionConfig getSessionConfig()
IoSession
s
created by this service.protected ConnectFuture connect0(SocketAddress remoteAddress, SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
connect0
in class AbstractIoConnector
remoteAddress
- The remote address to connect fromlocalAddress
- null if no local address is specifiedsessionInitializer
- The IoSessionInitializer to use when the connection s successfulprotected void dispose0() throws Exception
AbstractIoService.dispose()
.dispose0
in class AbstractIoService
Exception
- If the dispose failedCopyright © 2004–2021 Apache MINA Project. All rights reserved.