Package org.opennms.netmgt.provision.support

Class ConnectionFactoryNewConnectorImpl

java.lang.Object

org.opennms.netmgt.provision.support.ConnectionFactory

org.opennms.netmgt.provision.support.ConnectionFactoryNewConnectorImpl

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.

Author:

Seth, ranger, Duncan Mackintosh

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionFactoryNewConnectorImpl(int timeoutInMillis)	Create a new factory.

Method Summary

Modifier and Type	Method	Description
org.apache.mina.core.future.ConnectFuture	connect(java.net.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(java.net.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.

Methods inherited from class org.opennms.netmgt.provision.support.ConnectionFactory

dispose, getFactory, getTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionFactoryNewConnectorImpl

protected ConnectionFactoryNewConnectorImpl(int timeoutInMillis)

Create a new factory. Private because one should use ConnectionFactory.getFactory(int)

Method Detail

connect

public org.apache.mina.core.future.ConnectFuture connect(java.net.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).

Specified by:

connect in class ConnectionFactory

Parameters:

remoteAddress - Destination address

init - Initialiser for the IoSession

Returns:

ConnectFuture from a Mina connect call

reConnect

public org.apache.mina.core.future.ConnectFuture reConnect(java.net.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.

Specified by:

reConnect in class ConnectionFactory

Parameters:

remoteAddress -

localAddress -

init -

handler -

Returns:

dispose

protected void dispose()

Description copied from class: ConnectionFactory

Dispose of any resources that are held by the connection.

Specified by:

dispose in class ConnectionFactory