org.apache.synapse.transport.passthru.connections

Class TargetConnections

java.lang.Object

org.apache.synapse.transport.passthru.connections.TargetConnections

public class TargetConnections
extends Object

Manages the connection from transport to the back end servers. It keeps track of the connections for host:port pair.

Constructor Summary

Constructors

Constructor and Description
TargetConnections(org.apache.http.nio.reactor.ConnectingIOReactor ioReactor, TargetConfiguration targetConfiguration, ConnectCallback callback) Create a TargetConnections with the given IO-Reactor

Method Summary

Modifier and Type	Method and Description
void	addConnection(org.apache.http.nio.NHttpClientConnection conn) This method is called when a new connection is made.
void	closeConnection(org.apache.http.nio.NHttpClientConnection conn) This connection is no longer needed.
org.apache.http.nio.NHttpClientConnection	getConnection(String host, int port) Return a connection to the host:port pair.
org.apache.http.nio.NHttpClientConnection	getExistingConnection(String host, int port) Return an existing connection to the host:port pair from connection pool.
void	releaseConnection(org.apache.http.nio.NHttpClientConnection conn) Release an active connection to the pool
void	shutdownConnection(org.apache.http.nio.NHttpClientConnection conn) This connection is no longer valid.
void	shutdownConnection(org.apache.http.nio.NHttpClientConnection conn, boolean isError) This connection is no longer valid.

Methods inherited from class java.lang.Object

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

Constructor Detail

TargetConnections

public TargetConnections(org.apache.http.nio.reactor.ConnectingIOReactor ioReactor,
                         TargetConfiguration targetConfiguration,
                         ConnectCallback callback)

Create a TargetConnections with the given IO-Reactor

Parameters:

ioReactor - the IO-Reactor

targetConfiguration - the configuration of the sender

callback - the callback

Method Detail

getConnection

public org.apache.http.nio.NHttpClientConnection getConnection(String host,
                                                               int port)

Return a connection to the host:port pair. If a connection is not available return null. If the particular host:port allows to create more connections this method will try to connect asynchronously. If the connection is successful it will be notified in a separate thread.

Parameters:

host - host

port - port

Returns:

Either returns a connection if already available or returns null and notifies the delivery agent when the connection is available

getExistingConnection

public org.apache.http.nio.NHttpClientConnection getExistingConnection(String host,
                                                                       int port)

Return an existing connection to the host:port pair from connection pool. If a connection is not available, return null

Parameters:

host - host

port - port

Returns:

returns a connection if already available in the pool

closeConnection

public void closeConnection(org.apache.http.nio.NHttpClientConnection conn)

This connection is no longer needed. So we need to close connection.

Parameters:

conn - connection to shutdownConnection

shutdownConnection

public void shutdownConnection(org.apache.http.nio.NHttpClientConnection conn)

This connection is no longer valid. So we need to shutdown connection.

Parameters:

conn - connection to shutdownConnection

shutdownConnection

public void shutdownConnection(org.apache.http.nio.NHttpClientConnection conn,
                               boolean isError)

This connection is no longer valid. So we need to shutdown connection.

Parameters:

conn - connection to shutdownConnection

isError - whether an error is causing this shutdown of the connection. It is very important to set this flag correctly. When an error causing the shutdown of the connections we should not release associated writer buffer to the pool as it might lead into situations like same buffer is getting released to both source and target buffer factories

releaseConnection

public void releaseConnection(org.apache.http.nio.NHttpClientConnection conn)

Release an active connection to the pool

Parameters:

conn - connection to be released

addConnection

public void addConnection(org.apache.http.nio.NHttpClientConnection conn)

This method is called when a new connection is made.

Parameters:

conn - connection to the target server