public class TargetConnections
extends java.lang.Object
Constructor and Description |
---|
TargetConnections(org.apache.http.nio.reactor.ConnectingIOReactor ioReactor,
TargetConfiguration targetConfiguration,
ConnectCallback callback)
Create a TargetConnections with the given IO-Reactor
|
Modifier and Type | Method and Description |
---|---|
void |
addConnection(org.apache.http.nio.NHttpClientConnection conn)
This method is called when a new connection is made.
|
org.apache.http.nio.NHttpClientConnection |
getConnection(org.apache.http.conn.routing.HttpRoute route,
org.apache.axis2.context.MessageContext msgContext,
TargetErrorHandler targetErrorHandler,
java.util.Queue<org.apache.axis2.context.MessageContext> queue)
Return a connection to the host:port pair.
|
org.apache.http.nio.NHttpClientConnection |
getExistingConnection(org.apache.http.conn.routing.HttpRoute route) |
void |
releaseConnection(org.apache.http.nio.NHttpClientConnection conn)
Release an active connection to the pool
|
void |
resetConnectionPool(java.util.Set<java.lang.String> hostList)
Shutdown the connections of the given host:port list.
|
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.
|
public TargetConnections(org.apache.http.nio.reactor.ConnectingIOReactor ioReactor, TargetConfiguration targetConfiguration, ConnectCallback callback)
ioReactor
- the IO-ReactortargetConfiguration
- the configuration of the sendercallback
- the callbackpublic org.apache.http.nio.NHttpClientConnection getConnection(org.apache.http.conn.routing.HttpRoute route, org.apache.axis2.context.MessageContext msgContext, TargetErrorHandler targetErrorHandler, java.util.Queue<org.apache.axis2.context.MessageContext> queue)
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.route
- Http routepublic org.apache.http.nio.NHttpClientConnection getExistingConnection(org.apache.http.conn.routing.HttpRoute route)
public void shutdownConnection(org.apache.http.nio.NHttpClientConnection conn)
conn
- connection to shutdownConnectionpublic void shutdownConnection(org.apache.http.nio.NHttpClientConnection conn, boolean isError)
conn
- connection to shutdownConnectionisError
- 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 factoriespublic void releaseConnection(org.apache.http.nio.NHttpClientConnection conn)
conn
- connection to be releasedpublic void addConnection(org.apache.http.nio.NHttpClientConnection conn)
conn
- connection to the target serverpublic void resetConnectionPool(java.util.Set<java.lang.String> hostList)
hostList
- Set of String which contains entries in hots:port formatCopyright © 2005-2021 Apache Software Foundation. All Rights Reserved.