public class ConnectionFactoryNewConnectorImpl extends ConnectionFactory
This ConnectionFactory
type will create a new NioSocketConnector
for every call to #connect(SocketAddress, SocketAddress, IoSessionInitializer)
.
This is a naive implementation that does not really take advantage of the asynchronous
operations in MINA since it is creating new threads for each socket operation.
Modifier | Constructor and Description |
---|---|
protected |
ConnectionFactoryNewConnectorImpl(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 recreating connectors during each invocation. |
dispose, getFactory, getTimeout
protected ConnectionFactoryNewConnectorImpl(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 ConnectionFactoryNewConnectorImpl
and ConnectFuture
when done
by calling #dispose(ConnectionFactoryNewConnectorImpl, 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 recreating connectors during each invocation.reConnect
in class ConnectionFactory
remoteAddress
- localAddress
- init
- handler
- protected void dispose()
ConnectionFactory
dispose
in class ConnectionFactory
Copyright © 2020. All rights reserved.