Package | Description |
---|---|
org.apache.mina.core.future | |
org.apache.mina.core.polling |
Base class for implementing transport based on active polling strategies like NIO select call,
or any API based on I/O polling system calls (epoll, poll, select, kqueue, etc).
|
org.apache.mina.core.service | |
org.apache.mina.proxy | |
org.apache.mina.proxy.session | |
org.apache.mina.transport.serial | |
org.apache.mina.transport.vmpipe |
In-VM pipe support which removes the overhead of local loopback communication.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultConnectFuture
A default implementation of
ConnectFuture . |
Modifier and Type | Method and Description |
---|---|
ConnectFuture |
DefaultConnectFuture.addListener(IoFutureListener<?> listener)
Adds an event listener which is notified when
this future is completed.
|
ConnectFuture |
ConnectFuture.addListener(IoFutureListener<?> listener)
Adds an event listener which is notified when
this future is completed.
|
ConnectFuture |
DefaultConnectFuture.await()
Wait for the asynchronous operation to complete.
|
ConnectFuture |
ConnectFuture.await()
Wait for the asynchronous operation to complete.
|
ConnectFuture |
DefaultConnectFuture.awaitUninterruptibly()
Wait for the asynchronous operation to complete uninterruptibly.
|
ConnectFuture |
ConnectFuture.awaitUninterruptibly()
Wait for the asynchronous operation to complete uninterruptibly.
|
static ConnectFuture |
DefaultConnectFuture.newFailedFuture(Throwable exception)
Creates a new instance of a Connection Failure, with the associated cause.
|
ConnectFuture |
DefaultConnectFuture.removeListener(IoFutureListener<?> listener)
Removes an existing event listener so it won't be notified when
the future is completed.
|
ConnectFuture |
ConnectFuture.removeListener(IoFutureListener<?> listener)
Removes an existing event listener so it won't be notified when
the future is completed.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPollingIoConnector.ConnectionRequest
A ConnectionRequest's Iouture
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
AbstractPollingIoConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Modifier and Type | Method and Description |
---|---|
IoSessionInitializer<? extends ConnectFuture> |
AbstractPollingIoConnector.ConnectionRequest.getSessionInitializer() |
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
AbstractPollingIoConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Constructor and Description |
---|
ConnectionRequest(H handle,
IoSessionInitializer<? extends ConnectFuture> callback)
Creates a new ConnectionRequest instance
|
Modifier and Type | Method and Description |
---|---|
ConnectFuture |
IoConnector.connect()
Connects to the
default
remote address . |
ConnectFuture |
AbstractIoConnector.connect()
Connects to the
default
remote address . |
ConnectFuture |
IoConnector.connect(IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the
default
remote address and invokes the ioSessionInitializer when
the IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
AbstractIoConnector.connect(IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the
default
remote address and invokes the ioSessionInitializer when
the IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress)
Connects to the specified remote address.
|
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress)
Connects to the specified remote address.
|
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address and invokes
the
ioSessionInitializer when the IoSession is created but before
IoHandler.sessionCreated(IoSession) is invoked. |
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address and invokes
the
ioSessionInitializer when the IoSession is created but before
IoHandler.sessionCreated(IoSession) is invoked. |
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connects to the specified remote address binding to the specified local address.
|
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connects to the specified remote address binding to the specified local address.
|
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address binding to the specified local
address and and invokes the
ioSessionInitializer when the
IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address binding to the specified local
address and and invokes the
ioSessionInitializer when the
IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
protected abstract ConnectFuture |
AbstractIoConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Modifier and Type | Method and Description |
---|---|
ConnectFuture |
IoConnector.connect(IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the
default
remote address and invokes the ioSessionInitializer when
the IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
AbstractIoConnector.connect(IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the
default
remote address and invokes the ioSessionInitializer when
the IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address and invokes
the
ioSessionInitializer when the IoSession is created but before
IoHandler.sessionCreated(IoSession) is invoked. |
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address and invokes
the
ioSessionInitializer when the IoSession is created but before
IoHandler.sessionCreated(IoSession) is invoked. |
ConnectFuture |
IoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address binding to the specified local
address and and invokes the
ioSessionInitializer when the
IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
ConnectFuture |
AbstractIoConnector.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified remote address binding to the specified local
address and and invokes the
ioSessionInitializer when the
IoSession is created but before IoHandler.sessionCreated(IoSession)
is invoked. |
protected abstract ConnectFuture |
AbstractIoConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
ProxyConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified
address . |
protected ConnectFuture |
ProxyConnector.fireConnected(IoSession session)
Fires the connection event on the real future to notify the client.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
ProxyConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified
address . |
Modifier and Type | Class and Description |
---|---|
class |
ProxyIoSessionInitializer<T extends ConnectFuture>
ProxyIoSessionInitializer.java -
IoSessionInitializer wrapper class to inject the
ProxyIoSession object that contains all the attributes of the target connection
into the IoSession . |
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
SerialConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer) |
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
SerialConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer) |
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
VmPipeConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
VmPipeConnector.connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Implement this method to perform the actual connect operation.
|
Copyright © 2004–2018 Apache MINA Project. All rights reserved.