public class ConnectionFactoryConnectorPoolImpl extends ConnectionFactory
Factory for encapsulating a NioSocketConnector
in such a way as to allow us
to reuse the connector for each #connect(SocketAddress, SocketAddress, IoSessionInitializer, IoHandler)
call.
There will be one ConnectionFactory for each discrete connection timeout value.
Modifier | Constructor and Description |
---|---|
protected |
ConnectionFactoryConnectorPoolImpl(int timeoutInMillis)
Create a new factory.
|
Modifier and Type | Method and Description |
---|---|
org.apache.mina.core.future.ConnectFuture |
connect(SocketAddress remoteAddress,
org.apache.mina.core.session.IoSessionInitializer<? extends org.apache.mina.core.future.ConnectFuture> init,
org.apache.mina.core.service.IoHandler handler)
Connect to a remote socket.
|
protected void |
dispose()
Dispose of any resources that are held by the connection.
|
org.apache.mina.core.future.ConnectFuture |
reConnect(SocketAddress remoteAddress,
org.apache.mina.core.session.IoSessionInitializer<? extends org.apache.mina.core.future.ConnectFuture> init,
org.apache.mina.core.service.IoHandler handler)
Delegates completely to
#connect(SocketAddress, SocketAddress, IoSessionInitializer, IoHandler)
since we are reusing the same connector for all invocations. |
dispose, getFactory, getTimeout
protected ConnectionFactoryConnectorPoolImpl(int timeoutInMillis)
ConnectionFactory.getFactory(int)
public org.apache.mina.core.future.ConnectFuture connect(SocketAddress remoteAddress, org.apache.mina.core.session.IoSessionInitializer<? extends org.apache.mina.core.future.ConnectFuture> init, org.apache.mina.core.service.IoHandler handler)
Connect to a remote socket. If org.opennms.netmgt.provision.maxConcurrentConnections is set, this may block until a connection slot is available.
You must dispose both the ConnectionFactoryConnectorPoolImpl
and ConnectFuture
when done
by calling #dispose(ConnectionFactoryConnectorPoolImpl, ConnectFuture)
.
connect
in class ConnectionFactory
remoteAddress
- Destination addressinit
- Initialiser for the IoSessionpublic org.apache.mina.core.future.ConnectFuture reConnect(SocketAddress remoteAddress, org.apache.mina.core.session.IoSessionInitializer<? extends org.apache.mina.core.future.ConnectFuture> init, org.apache.mina.core.service.IoHandler handler)
#connect(SocketAddress, SocketAddress, IoSessionInitializer, IoHandler)
since we are reusing the same connector for all invocations.reConnect
in class ConnectionFactory
remoteAddress
- localAddress
- init
- handler
- protected void dispose()
ConnectionFactory
dispose
in class ConnectionFactory
Copyright © 2018. All rights reserved.