Class VmPipeConnector

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoConnector

org.apache.mina.transport.vmpipe.VmPipeConnector

All Implemented Interfaces:

IoConnector, IoService

public final class VmPipeConnector
extends AbstractIoConnector

Connects to IoHandlers which is bound on the specified VmPipeAddress.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	VmPipeConnector.LocalAddressReclaimer

Nested classes/interfaces inherited from class AbstractIoService

AbstractIoService.ServiceOperationFuture

Field Summary

Fields

Modifier and Type	Field	Description
private IdleStatusChecker	idleChecker
private static final IoFutureListener<IoFuture>	LOCAL_ADDRESS_RECLAIMER
private static int	nextLocalPort
private static final Set<VmPipeAddress>	TAKEN_LOCAL_ADDRESSES

Fields inherited from class AbstractIoService

disposalLock, LOGGER, sessionConfig

Constructor Summary

Constructors

Constructor	Description
VmPipeConnector()	Creates a new instance.
VmPipeConnector(Executor executor)	Creates a new instance.

Method Summary

Modifier and Type	Method	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()
private static VmPipeAddress	nextLocalAddress()

Methods inherited from class AbstractIoConnector

connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultLocalAddress, getDefaultRemoteAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultLocalAddress, setDefaultRemoteAddress, toString

Methods inherited from class AbstractIoService

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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Field Details

idleChecker

private IdleStatusChecker idleChecker

TAKEN_LOCAL_ADDRESSES

private static final Set<VmPipeAddress> TAKEN_LOCAL_ADDRESSES

nextLocalPort

private static int nextLocalPort

LOCAL_ADDRESS_RECLAIMER

private static final IoFutureListener<IoFuture> LOCAL_ADDRESS_RECLAIMER

Constructor Details

VmPipeConnector

public VmPipeConnector()

Creates a new instance.

VmPipeConnector

public VmPipeConnector(Executor executor)

Creates a new instance.

Parameters:

executor - The executor to use

Method Details

getTransportMetadata

public TransportMetadata getTransportMetadata()

Returns:

the TransportMetadata that this service runs on.

getSessionConfig

public VmPipeSessionConfig getSessionConfig()

Returns:

the default configuration of the new IoSessions created by this service.

connect0

protected ConnectFuture connect0(SocketAddress remoteAddress,
 SocketAddress localAddress,
 IoSessionInitializer<? extends ConnectFuture> sessionInitializer)

Implement this method to perform the actual connect operation.

Specified by:

connect0 in class AbstractIoConnector

Parameters:

remoteAddress - The remote address to connect from

localAddress - null if no local address is specified

sessionInitializer - The IoSessionInitializer to use when the connection s successful

Returns:

The ConnectFuture associated with this asynchronous operation

dispose0

protected void dispose0()
                 throws Exception

Implement this method to release any acquired resources. This method is invoked only once by AbstractIoService.dispose().

Specified by:

dispose0 in class AbstractIoService

Throws:

Exception - If the dispose failed

nextLocalAddress

private static VmPipeAddress nextLocalAddress()
                                       throws IOException

Throws:

IOException