Class HttpDestination

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.client.HttpDestination

All Implemented Interfaces:

Closeable, AutoCloseable, Destination, Callback, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, Invocable

Direct Known Subclasses:

MultiplexHttpDestination, PoolingHttpDestination

@ManagedObject
public abstract class HttpDestination
extends ContainerLifeCycle
implements Destination, Closeable, Callback, Dumpable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	HttpDestination.TimeoutTask	This class enforces the total timeout for exchanges that are still in the queue.

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface Callback

Callback.Completable, Callback.Completing, Callback.InvocableCallback, Callback.Nested

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface Invocable

Invocable.InvocationType

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private final HttpClient	client
private final ClientConnectionFactory	connectionFactory
private ConnectionPool	connectionPool
private final Queue<HttpExchange>	exchanges
private final HttpField	hostField
protected static final Logger	LOG
private final Origin	origin
private final ProxyConfiguration.Proxy	proxy
private final RequestNotifier	requestNotifier
private final ResponseNotifier	responseNotifier
private final HttpDestination.TimeoutTask	timeout

Fields inherited from class AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Callback

NOOP

Fields inherited from interface Dumpable

KEY

Fields inherited from interface Invocable

__nonBlocking

Constructor Summary

Constructors

Constructor	Description
HttpDestination(HttpClient client, Origin origin)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable cause)	Aborts all the HttpExchanges queued in this destination.
String	asString()
void	close()
void	close(Connection connection)	Deprecated. use remove(Connection) instead
protected void	createConnection(Promise<Connection> promise)
protected void	doStart()	Starts the managed lifecycle beans in the order they were added.
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
protected boolean	enqueue(Queue<HttpExchange> queue, HttpExchange exchange)
void	failed(Throwable x)	Callback invoked when the operation fails.
ClientConnectionFactory	getClientConnectionFactory()
Origin.Address	getConnectAddress()
ConnectionPool	getConnectionPool()
String	getHost()
HttpField	getHostField()
HttpClient	getHttpClient()
Queue<HttpExchange>	getHttpExchanges()
Origin	getOrigin()
int	getPort()
ProxyConfiguration.Proxy	getProxy()
int	getQueuedRequestCount()
RequestNotifier	getRequestNotifier()
ResponseNotifier	getResponseNotifier()
String	getScheme()
boolean	isSecure()
void	newConnection(Promise<Connection> promise)	Creates asynchronously a new, unpooled, Connection that will be returned at a later time through the given Promise.
protected ConnectionPool	newConnectionPool(HttpClient client)
protected Queue<HttpExchange>	newExchangeQueue(HttpClient client)
protected ClientConnectionFactory	newSslClientConnectionFactory(ClientConnectionFactory connectionFactory)	Deprecated. use newSslClientConnectionFactory(SslContextFactory, ClientConnectionFactory) instead
protected ClientConnectionFactory	newSslClientConnectionFactory(SslContextFactory sslContextFactory, ClientConnectionFactory connectionFactory)
private void	process(boolean create)
private boolean	process(Connection connection)
void	release(Connection connection)
boolean	remove(Connection connection)
boolean	remove(HttpExchange exchange)
void	send()
private void	send(boolean create)
protected abstract SendFailure	send(Connection connection, HttpExchange exchange)
void	send(Request request, Response.CompleteListener listener)
void	send(HttpExchange exchange)
protected void	send(HttpRequest request, List<Response.ResponseListener> listeners)
void	succeeded()	Callback invoked when the operation completes.
String	toString()
private void	tryRemoveIdleDestination()

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans

Methods inherited from class AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class Object

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

Methods inherited from interface Dumpable

dump, dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Methods inherited from interface Invocable

getInvocationType

Field Details

LOG

protected static final Logger LOG

client

private final HttpClient client

origin

private final Origin origin

exchanges

private final Queue<HttpExchange> exchanges

requestNotifier

private final RequestNotifier requestNotifier

responseNotifier

private final ResponseNotifier responseNotifier

proxy

private final ProxyConfiguration.Proxy proxy

connectionFactory

private final ClientConnectionFactory connectionFactory

hostField

private final HttpField hostField

timeout

private final HttpDestination.TimeoutTask timeout

connectionPool

private ConnectionPool connectionPool

Constructor Details

HttpDestination

public HttpDestination(HttpClient client,
 Origin origin)

Method Details

doStart

protected void doStart()
                throws Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception

newConnectionPool

protected ConnectionPool newConnectionPool(HttpClient client)

newExchangeQueue

protected Queue<HttpExchange> newExchangeQueue(HttpClient client)

newSslClientConnectionFactory

@Deprecated
protected ClientConnectionFactory newSslClientConnectionFactory(ClientConnectionFactory connectionFactory)

Deprecated.

use newSslClientConnectionFactory(SslContextFactory, ClientConnectionFactory) instead

Creates a new SslClientConnectionFactory wrapping the given connection factory.

Parameters:

connectionFactory - the connection factory to wrap

Returns:

a new SslClientConnectionFactory

newSslClientConnectionFactory

protected ClientConnectionFactory newSslClientConnectionFactory(SslContextFactory sslContextFactory,
 ClientConnectionFactory connectionFactory)

isSecure

public boolean isSecure()

getHttpClient

public HttpClient getHttpClient()

getOrigin

public Origin getOrigin()

getHttpExchanges

public Queue<HttpExchange> getHttpExchanges()

getRequestNotifier

public RequestNotifier getRequestNotifier()

getResponseNotifier

public ResponseNotifier getResponseNotifier()

getProxy

public ProxyConfiguration.Proxy getProxy()

getClientConnectionFactory

public ClientConnectionFactory getClientConnectionFactory()

getScheme

@ManagedAttribute(value="The destination scheme",
                  readonly=true)
public String getScheme()

Specified by:

getScheme in interface Destination

Returns:

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

getHost

@ManagedAttribute(value="The destination host",
                  readonly=true)
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

@ManagedAttribute(value="The destination port",
                  readonly=true)
public int getPort()

Specified by:

getPort in interface Destination

Returns:

the port of this destination such as 80 or 443

getQueuedRequestCount

@ManagedAttribute(value="The number of queued requests",
                  readonly=true)
public int getQueuedRequestCount()

getConnectAddress

public Origin.Address getConnectAddress()

getHostField

public HttpField getHostField()

getConnectionPool

@ManagedAttribute(value="The connection pool",
                  readonly=true)
public ConnectionPool getConnectionPool()

succeeded

public void succeeded()

Description copied from interface: Callback

Callback invoked when the operation completes.

Specified by:

succeeded in interface Callback

See Also:

• Callback.failed(Throwable)

failed

public void failed(Throwable x)

Description copied from interface: Callback

Callback invoked when the operation fails.

Specified by:

failed in interface Callback

Parameters:

x - the reason for the operation failure

send

public void send(Request request,
 Response.CompleteListener listener)

send

protected void send(HttpRequest request,
 List<Response.ResponseListener> listeners)

send

public void send(HttpExchange exchange)

enqueue

protected boolean enqueue(Queue<HttpExchange> queue,
 HttpExchange exchange)

send

public void send()

send

private void send(boolean create)

process

private void process(boolean create)

process

private boolean process(Connection connection)

send

protected abstract SendFailure send(Connection connection,
 HttpExchange exchange)

newConnection

public void newConnection(Promise<Connection> promise)

Description copied from interface: Destination

Creates asynchronously a new, unpooled, Connection that will be returned at a later time through the given Promise.

Use FuturePromise to wait for the connection:

Destination destination = ...;
FuturePromise<Connection> futureConnection = new FuturePromise<>();
destination.newConnection(futureConnection);
Connection connection = futureConnection.get(5, TimeUnit.SECONDS);

Specified by:

newConnection in interface Destination

Parameters:

promise - the promise of a new, unpooled, Connection

createConnection

protected void createConnection(Promise<Connection> promise)

remove

public boolean remove(HttpExchange exchange)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

release

public void release(Connection connection)

remove

public boolean remove(Connection connection)

close

@Deprecated
public void close(Connection connection)

Deprecated.

use remove(Connection) instead

Parameters:

connection - the connection to remove

abort

public void abort(Throwable cause)

Aborts all the HttpExchanges queued in this destination.

Parameters:

cause - the abort cause

tryRemoveIdleDestination

private void tryRemoveIdleDestination()

dump

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

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable

asString

public String asString()

toString

public String toString()

Overrides:

toString in class AbstractLifeCycle