org.eclipse.jetty.client

Class HttpDestination

java.lang.Object

org.eclipse.jetty.client.HttpDestination

All Implemented Interfaces:

AutoCloseable, Destination, Dumpable

public class HttpDestination
extends Object
implements Destination, AutoCloseable, Dumpable

Constructor Summary

Constructors

Constructor and Description
HttpDestination(HttpClient client, String scheme, String host, int port)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	abort(Request request, String reason)
protected Connection	acquire()
void	close()
String	dump()
void	dump(Appendable out, String indent)
protected BlockingQueue<Connection>	getActiveConnections()
String	getHost()
protected BlockingQueue<Connection>	getIdleConnections()
int	getPort()
String	getScheme()
Future<Connection>	newConnection()
protected void	newConnection(Callback<Connection> callback)
protected void	process(Connection connection, boolean dispatch) Processes a new connection making it idle or active depending on whether requests are waiting to be sent.
void	release(Connection connection)
void	remove(Connection connection)
void	send(Request request, List<Response.ResponseListener> listeners)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpDestination

public HttpDestination(HttpClient client,
               String scheme,
               String host,
               int port)

Method Detail

getIdleConnections

protected BlockingQueue<Connection> getIdleConnections()

getActiveConnections

protected BlockingQueue<Connection> getActiveConnections()

getScheme

public String getScheme()

Specified by:

getScheme in interface Destination

Returns:

the scheme of this destination, such as "http" or "https"

getHost

public String getHost()

Specified by:

getHost in interface Destination

Returns:

the host of this destination, such as "127.0.0.1" or "google.com"

getPort

public int getPort()

Specified by:

getPort in interface Destination

Returns:

the port of this destination such as 80 or 443

send

public void send(Request request,
        List<Response.ResponseListener> listeners)

newConnection

public Future<Connection> newConnection()

Specified by:

newConnection in interface Destination

Returns:

a future to a new, unpooled, Connection

newConnection

protected void newConnection(Callback<Connection> callback)

acquire

protected Connection acquire()

process

protected void process(Connection connection,
           boolean dispatch)

Processes a new connection making it idle or active depending on whether requests are waiting to be sent.

A new connection is created when a request needs to be executed; it is possible that the request that triggered the request creation is executed by another connection that was just released, so the new connection may become idle.

If a request is waiting to be executed, it will be dequeued and executed by the new connection.

Parameters:

connection - the new connection

release

public void release(Connection connection)

remove

public void remove(Connection connection)

close

public void close()

Specified by:

close in interface AutoCloseable

abort

public boolean abort(Request request,
            String reason)

dump

public String dump()

Specified by:

dump in interface Dumpable

dump

public void dump(Appendable out,
        String indent)
          throws IOException

Specified by:

dump in interface Dumpable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object