public final class VmPipeConnector extends AbstractIoConnector
IoHandler
s which is bound on the specified
VmPipeAddress
.AbstractIoService.ServiceOperationFuture
disposalLock, sessionConfig
构造器和说明 |
---|
VmPipeConnector()
Creates a new instance.
|
VmPipeConnector(java.util.concurrent.Executor executor)
Creates a new instance.
|
限定符和类型 | 方法和说明 |
---|---|
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() |
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(java.util.concurrent.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(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
connect0
在类中 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 java.lang.Exception
AbstractIoService.dispose()
.dispose0
在类中 AbstractIoService
java.lang.Exception
- If the dispose failed