class ProxyFilter extends Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ProxyFilter.State |
Modifier and Type | Field and Description |
---|---|
private java.net.InetSocketAddress |
originalDestinationAddress |
private ConnectorConfiguration.ProxyConfiguration |
proxyConfiguration |
private ProxyDigestAuthenticator |
proxyDigestAuthenticator |
private ProxyFilter.State |
state |
downstreamFilter, upstreamFilter
Constructor and Description |
---|
ProxyFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter,
ConnectorConfiguration.ProxyConfiguration proxyConfiguration)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
connect(java.net.SocketAddress address,
Filter<?,?,HttpRequest,HttpResponse> upstreamFilter)
Initiate connect.
|
private HttpRequest |
createAuthenticatingRequest(HttpResponse httpResponse) |
private HttpRequest |
createConnectRequest() |
private java.lang.String |
getOriginalDestinationUri() |
private void |
handleError(java.lang.Throwable t) |
(package private) void |
onConnect()
An event listener that is called when a connection is set up.
|
(package private) boolean |
processRead(HttpResponse httpResponse)
Process
Filter.onRead(Object) . |
(package private) void |
write(HttpRequest data,
CompletionHandler<HttpRequest> completionHandler)
Perform write operation for this filter and invokes write method on the next filter in the filter chain.
|
close, handleConnect, onConnectionClosed, onError, onRead, onSslHandshakeCompleted, processConnect, processConnectionClosed, processError, processSslHandshakeCompleted, startSsl
private final ConnectorConfiguration.ProxyConfiguration proxyConfiguration
private final ProxyDigestAuthenticator proxyDigestAuthenticator
private volatile ProxyFilter.State state
private volatile java.net.InetSocketAddress originalDestinationAddress
ProxyFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter, ConnectorConfiguration.ProxyConfiguration proxyConfiguration)
downstreamFilter
- downstream filter. Accessible directly as Filter.downstreamFilter
protected field.void connect(java.net.SocketAddress address, Filter<?,?,HttpRequest,HttpResponse> upstreamFilter)
Filter
Filter
needs to do something during this phase, it must implement Filter.handleConnect(SocketAddress, Filter)
method.connect
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
address
- an address where to connect (server or proxy).upstreamFilter
- a filter positioned upstream.void onConnect()
Filter
Filter
needs to process this event, it must implement Filter.processConnect()
method.onConnect
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
boolean processRead(HttpResponse httpResponse)
Filter
Filter.onRead(Object)
.processRead
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
httpResponse
- read data.true
if the data should be sent to processing to upper filter in the chain, false
otherwise.Filter.onRead(Object).
void write(HttpRequest data, CompletionHandler<HttpRequest> completionHandler)
Filter
write
in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
data
- on which write operation is performed.completionHandler
- will be invoked when the write operation is completed or has failed.private void handleError(java.lang.Throwable t)
private HttpRequest createAuthenticatingRequest(HttpResponse httpResponse) throws ProxyAuthenticationException
ProxyAuthenticationException
private HttpRequest createConnectRequest()
private java.lang.String getOriginalDestinationUri()