Modifier and Type	Class and Description
private static class	HttpProxy.CreateTunnelPromise Creates a tunnel using HTTP CONNECT.
private class	HttpProxy.HttpProxyClientConnectionFactory
private static class	HttpProxy.ProxyConnection
private static class	HttpProxy.TunnelPromise

Modifier and Type	Field and Description
private static final Logger	LOG

Access	Constructor and Description
public	HttpProxy(String host, int port)
public	HttpProxy(Origin.Address address, boolean secure)
public	HttpProxy(Origin.Address address, boolean secure, Origin.Protocol protocol)
public	HttpProxy(Origin.Address address, SslContextFactory.Client sslContextFactory)
public	HttpProxy(Origin.Address address, SslContextFactory.Client sslContextFactory, Origin.Protocol protocol)
private	HttpProxy(Origin.Address address, boolean secure, SslContextFactory.Client sslContextFactory, Origin.Protocol protocol)

Modifier and Type	Method and Description
public URI	getURI() Overrides org.eclipse.jetty.client.ProxyConfiguration.Proxy.getURI.
private boolean	isHTTP2(String protocol)
public ClientConnectionFactory	newClientConnectionFactory(ClientConnectionFactory the nested `ClientConnectionFactory` connectionFactory) Implements abstract org.eclipse.jetty.client.ProxyConfiguration.Proxy.newClientConnectionFactory.
private boolean	protocolMatches(String protocol, List<String> protocols)
public boolean	requiresTunnel(Origin serverOrigin)

LOG	back to summary
private static final Logger LOG

HttpProxy	back to summary
public HttpProxy(String host, int port)

HttpProxy	back to summary
public HttpProxy(Origin.Address address, boolean secure)

HttpProxy	back to summary
public HttpProxy(Origin.Address address, boolean secure, Origin.Protocol protocol)

HttpProxy	back to summary
public HttpProxy(Origin.Address address, SslContextFactory.Client sslContextFactory)

HttpProxy	back to summary
public HttpProxy(Origin.Address address, SslContextFactory.Client sslContextFactory, Origin.Protocol protocol)

HttpProxy	back to summary
private HttpProxy(Origin.Address address, boolean secure, SslContextFactory.Client sslContextFactory, Origin.Protocol protocol)

getURI	back to summary
public URI getURI() Overrides org.eclipse.jetty.client.ProxyConfiguration.Proxy.getURI. Returns:URI Doc from org.eclipse.jetty.client.ProxyConfiguration.Proxy.getURI. an URI representing this proxy, or null if no URI can represent this proxy Annotations @Override

isHTTP2	back to summary
private boolean isHTTP2(String protocol)

newClientConnectionFactory	back to summary
public ClientConnectionFactory newClientConnectionFactory(ClientConnectionFactory connectionFactory) Implements abstract org.eclipse.jetty.client.ProxyConfiguration.Proxy.newClientConnectionFactory. Parameters connectionFactory:ClientConnectionFactory Doc from org.eclipse.jetty.client.ProxyConfiguration.Proxy.newClientConnectionFactory. the nested `ClientConnectionFactory` Returns:ClientConnectionFactory Doc from org.eclipse.jetty.client.ProxyConfiguration.Proxy.newClientConnectionFactory. a new `ClientConnectionFactory` for this Proxy Annotations @Override

protocolMatches	back to summary
private boolean protocolMatches(String protocol, List<String> protocols)

requiresTunnel	back to summary
public boolean requiresTunnel(Origin serverOrigin)

org.eclipse.jetty.client back to summary

private Class HttpProxy.CreateTunnelPromise

Class Inheritance

extends Object
implements Promise<Connection>

java.lang.Object
org.eclipse.jetty.client.HttpProxy.CreateTunnelPromise

All Implemented Interfaces

org.eclipse.jetty.util.Promise

Creates a tunnel using HTTP CONNECT.

It is implemented as a promise because it needs to establish the tunnel after the TCP connection is succeeded, and needs to notify the nested promise when the tunnel is established (or failed).

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	HttpProxy.CreateTunnelPromise.TunnelListener

Field Summary

Modifier and Type	Field and Description
private final ClientConnectionFactory	connectionFactory
private final Map<String, Object>	context
private final HttpDestination	destination
private final EndPoint	endPoint
private final Promise<Connection>	promise

Constructor Summary

Access	Constructor and Description
private	CreateTunnelPromise(ClientConnectionFactory connectionFactory, EndPoint endPoint, HttpDestination destination, Promise<Connection> promise, Map<String, Object> context)

Method Summary

Modifier and Type	Method and Description
public void	failed(Throwable the reason for the operation failure x) Overrides default org.eclipse.jetty.util.Promise.failed. Callback invoked when the operation fails.
public void	succeeded(Connection the context connection) Overrides default org.eclipse.jetty.util.Promise.succeeded. Callback invoked when the operation completes.
private void	tunnel(Connection connection)
private void	tunnelFailed(EndPoint endPoint, Throwable failure)
private void	tunnelSucceeded(EndPoint endPoint)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connectionFactory	back to summary
private final ClientConnectionFactory connectionFactory

context	back to summary
private final Map<String, Object> context

destination	back to summary
private final HttpDestination destination

endPoint	back to summary
private final EndPoint endPoint

promise	back to summary
private final Promise<Connection> promise

Constructor Detail

CreateTunnelPromise	back to summary
private CreateTunnelPromise(ClientConnectionFactory connectionFactory, EndPoint endPoint, HttpDestination destination, Promise<Connection> promise, Map<String, Object> context)

Method Detail

failed	back to summary
public void failed(Throwable x) Overrides default org.eclipse.jetty.util.Promise.failed. Doc from org.eclipse.jetty.util.Promise.failed. Callback invoked when the operation fails. Parameters x:Throwable the reason for the operation failure Annotations @Override

failed

back to summary

public void failed(Throwable x)

Overrides default org.eclipse.jetty.util.Promise.failed.

Doc from org.eclipse.jetty.util.Promise.failed.

Callback invoked when the operation fails.

Parameters

x:Throwable: the reason for the operation failure

Annotations

@Override

succeeded	back to summary
public void succeeded(Connection connection) Overrides default org.eclipse.jetty.util.Promise.succeeded. Doc from org.eclipse.jetty.util.Promise.succeeded. Callback invoked when the operation completes. Parameters connection:Connection the context Annotations @Override

succeeded

back to summary

public void succeeded(Connection connection)

Overrides default org.eclipse.jetty.util.Promise.succeeded.

Doc from org.eclipse.jetty.util.Promise.succeeded.

Callback invoked when the operation completes.

Parameters

connection:Connection: the context

Annotations

@Override

tunnel	back to summary
private void tunnel(Connection connection)

tunnelFailed	back to summary
private void tunnelFailed(EndPoint endPoint, Throwable failure)

tunnelSucceeded	back to summary
private void tunnelSucceeded(EndPoint endPoint)

org.eclipse.jetty.client back to summary

private Class HttpProxy.CreateTunnelPromise.TunnelListener

Class Inheritance

extends Object
implements Listener

java.lang.Object
org.eclipse.jetty.client.HttpProxy.CreateTunnelPromise.TunnelListener

All Implemented Interfaces

Field Summary

Modifier and Type	Field and Description
private final HttpConversation	conversation

Constructor Summary

Access	Constructor and Description
private	TunnelListener(Request request)

Method Summary

Modifier and Type	Method and Description
public void	onComplete(Result the result of the request / response exchange result) Overrides default org.eclipse.jetty.client.Response.Listener.onComplete. Callback method invoked when the request and the response have been processed, either successfully or not.
public void	onHeaders(Response the response containing the response line data and the headers response) Overrides default org.eclipse.jetty.client.Response.Listener.onHeaders. Callback method invoked when all the response headers have been received and parsed.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

conversation	back to summary
private final HttpConversation conversation

Constructor Detail

TunnelListener	back to summary
private TunnelListener(Request request)

Method Detail

onComplete back to summary

onComplete	back to summary
public void onComplete(Result result) Overrides default org.eclipse.jetty.client.Response.Listener.onComplete. Doc from org.eclipse.jetty.client.Response.CompleteListener.onComplete. Callback method invoked when the request and the response have been processed, either successfully or not. The `result` parameter contains the request, the response, and eventual failures. Requests may complete after response, for example in case of big uploads that are discarded or read asynchronously by the server. This method is always invoked after `SuccessListener#onSuccess(Response)` or `FailureListener#onFailure(Response, Throwable)`, and only when request indicates that it is completed. Parameters result:Result the result of the request / response exchange Annotations @Override

public void onComplete(Result result)

Overrides default org.eclipse.jetty.client.Response.Listener.onComplete.

Doc from org.eclipse.jetty.client.Response.CompleteListener.onComplete.

Callback method invoked when the request and the response have been processed, either successfully or not.

The result parameter contains the request, the response, and eventual failures.

Requests may complete after response, for example in case of big uploads that are discarded or read asynchronously by the server. This method is always invoked after SuccessListener#onSuccess(Response) or FailureListener#onFailure(Response, Throwable), and only when request indicates that it is completed.

Parameters

result:Result: the result of the request / response exchange

Annotations

@Override

onHeaders	back to summary
public void onHeaders(Response response) Overrides default org.eclipse.jetty.client.Response.Listener.onHeaders. Doc from org.eclipse.jetty.client.Response.HeadersListener.onHeaders. Callback method invoked when all the response headers have been received and parsed. Parameters response:Response the response containing the response line data and the headers Annotations @Override

onHeaders

back to summary

public void onHeaders(Response response)

Overrides default org.eclipse.jetty.client.Response.Listener.onHeaders.

Doc from org.eclipse.jetty.client.Response.HeadersListener.onHeaders.

Callback method invoked when all the response headers have been received and parsed.

Parameters

response:Response: the response containing the response line data and the headers

Annotations

@Override

org.eclipse.jetty.client back to summary

private Class HttpProxy.HttpProxyClientConnectionFactory

Class Inheritance

extends Object
implements ClientConnectionFactory

java.lang.Object
org.eclipse.jetty.client.HttpProxy.HttpProxyClientConnectionFactory

All Implemented Interfaces

org.eclipse.jetty.io.ClientConnectionFactory

Field Summary

Modifier and Type	Field and Description
private final ClientConnectionFactory	connectionFactory

Constructor Summary

Access	Constructor and Description
private	HttpProxyClientConnectionFactory(ClientConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method and Description
public Connection	newConnection(EndPoint the `org.eclipse.jetty.io.EndPoint` to link the newly created connection to endPoint, Map<String, Object> the context data to create the connection context) Implements org.eclipse.jetty.io.ClientConnectionFactory.newConnection.
private Connection	newProxyConnection(EndPoint endPoint, Map<String, Object> context)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connectionFactory	back to summary
private final ClientConnectionFactory connectionFactory

Constructor Detail

HttpProxyClientConnectionFactory	back to summary
private HttpProxyClientConnectionFactory(ClientConnectionFactory connectionFactory)

Method Detail

newConnection back to summary

newConnection	back to summary
public Connection newConnection(EndPoint endPoint, Map<String, Object> context) throws IOException Implements org.eclipse.jetty.io.ClientConnectionFactory.newConnection. Parameters endPoint:EndPoint Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection. the `org.eclipse.jetty.io.EndPoint` to link the newly created connection to context:Map<String, Object> Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection. the context data to create the connection Returns:Connection Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection. a new `Connection` Annotations @Override Exceptions IOException: Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection. if the connection cannot be created

public Connection newConnection(EndPoint endPoint, Map<String, Object> context) throws IOException

Implements org.eclipse.jetty.io.ClientConnectionFactory.newConnection.

Parameters

endPoint:EndPoint

Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection.

the org.eclipse.jetty.io.EndPoint to link the newly created connection to

context:Map<String, Object>

Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection.

the context data to create the connection

Returns:Connection

Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection.

a new Connection

Annotations

@Override

Exceptions

IOException:

Doc from org.eclipse.jetty.io.ClientConnectionFactory.newConnection.

if the connection cannot be created

newProxyConnection	back to summary
private Connection newProxyConnection(EndPoint endPoint, Map<String, Object> context) throws IOException

org.eclipse.jetty.client back to summary

private Class HttpProxy.ProxyConnection

Class Inheritance

extends Object
implements Connection, Attachable

java.lang.Object
org.eclipse.jetty.client.HttpProxy.ProxyConnection

All Implemented Interfaces

org.eclipse.jetty.util.Attachable, org.eclipse.jetty.client.Connection, java.io.Closeable, java.lang.AutoCloseable

Field Summary

Modifier and Type	Field and Description
private Object	attachment
private final Connection	connection
private final Destination	destination
private final Promise<Connection>	promise

Constructor Summary

Access	Constructor and Description
private	ProxyConnection(Destination destination, Connection connection, Promise<Connection> promise)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements org.eclipse.jetty.client.Connection.close. Closes this stream and releases any system resources associated with it.
public Object	getAttachment() Implements org.eclipse.jetty.util.Attachable.getAttachment.
public SocketAddress	getLocalSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress.
public SocketAddress	getRemoteSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.
public boolean	isClosed() Implements org.eclipse.jetty.client.Connection.isClosed.
public void	send(Request the request to send request, Response.CompleteListener the response listener listener) Implements org.eclipse.jetty.client.Connection.send. Sends a request with an associated response listener.
public void	setAttachment(Object the object to attach to this instance obj) Implements org.eclipse.jetty.util.Attachable.setAttachment. Attaches the given object to this stream for later retrieval.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

attachment	back to summary
private Object attachment

connection	back to summary
private final Connection connection

destination	back to summary
private final Destination destination

promise	back to summary
private final Promise<Connection> promise

Constructor Detail

ProxyConnection	back to summary
private ProxyConnection(Destination destination, Connection connection, Promise<Connection> promise)

Method Detail

close back to summary

public void close()

Implements org.eclipse.jetty.client.Connection.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

getAttachment

back to summary

public Object getAttachment()

Implements org.eclipse.jetty.util.Attachable.getAttachment.

Returns:Object

Doc from org.eclipse.jetty.util.Attachable.getAttachment.

the object attached to this instance

Annotations

@Override

getLocalSocketAddress

back to summary

public SocketAddress getLocalSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress.

Returns:SocketAddress

Doc from org.eclipse.jetty.client.Connection.getLocalSocketAddress.

the local socket address associated with the connection

Annotations

@Override

getRemoteSocketAddress

back to summary

public SocketAddress getRemoteSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.

Returns:SocketAddress

Doc from org.eclipse.jetty.client.Connection.getRemoteSocketAddress.

the remote socket address associated with the connection

Annotations

@Override

isClosed

back to summary

public boolean isClosed()

Implements org.eclipse.jetty.client.Connection.isClosed.

Returns:boolean

Doc from org.eclipse.jetty.client.Connection.isClosed.

whether this connection has been closed

Annotations

@Override

send back to summary

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

Implements org.eclipse.jetty.client.Connection.send.

Doc from org.eclipse.jetty.client.Connection.send.

Sends a request with an associated response listener.

Request#send(Response.CompleteListener) will eventually call this method to send the request. It is exposed to allow applications to send requests via unpooled connections.

Parameters

request:Request: the request to send
listener:Response.CompleteListener: the response listener

Annotations

@Override

setAttachment

back to summary

public void setAttachment(Object obj)

Implements org.eclipse.jetty.util.Attachable.setAttachment.

Doc from org.eclipse.jetty.util.Attachable.setAttachment.

Attaches the given object to this stream for later retrieval.

Parameters

obj:Object: the object to attach to this instance

Annotations

@Override

org.eclipse.jetty.client back to summary

private Class HttpProxy.TunnelPromise

Class Inheritance

extends Object
implements Promise<Connection>

java.lang.Object
org.eclipse.jetty.client.HttpProxy.TunnelPromise

All Implemented Interfaces

org.eclipse.jetty.util.Promise

Field Summary

Modifier and Type	Field and Description
private final Response.CompleteListener	listener
private final Promise<Connection>	promise
private final Request	request

Constructor Summary

Access	Constructor and Description
private	TunnelPromise(Request request, Response.CompleteListener listener, Promise<Connection> promise)

Method Summary

Modifier and Type	Method and Description
public void	failed(Throwable the reason for the operation failure x) Overrides default org.eclipse.jetty.util.Promise.failed. Callback invoked when the operation fails.
public void	succeeded(Connection the context connection) Overrides default org.eclipse.jetty.util.Promise.succeeded. Callback invoked when the operation completes.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

listener	back to summary
private final Response.CompleteListener listener

promise	back to summary
private final Promise<Connection> promise

request	back to summary
private final Request request

Constructor Detail

TunnelPromise	back to summary
private TunnelPromise(Request request, Response.CompleteListener listener, Promise<Connection> promise)

Method Detail

failed

back to summary

public void failed(Throwable x)

Overrides default org.eclipse.jetty.util.Promise.failed.

Doc from org.eclipse.jetty.util.Promise.failed.

Callback invoked when the operation fails.

Parameters

x:Throwable: the reason for the operation failure

Annotations

@Override

succeeded

back to summary

public void succeeded(Connection connection)

Overrides default org.eclipse.jetty.util.Promise.succeeded.

Doc from org.eclipse.jetty.util.Promise.succeeded.

Callback invoked when the operation completes.

Parameters

connection:Connection: the context

Annotations

@Override

public Class HttpProxy

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpProxy.CreateTunnelPromise

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpProxy.CreateTunnelPromise.TunnelListener

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpProxy.HttpProxyClientConnectionFactory

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpProxy.ProxyConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpProxy.TunnelPromise

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail