Package org.glassfish.jersey.jdk.connector.internal

Class ProxyFilter

java.lang.Object

org.glassfish.jersey.jdk.connector.internal.Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

org.glassfish.jersey.jdk.connector.internal.ProxyFilter

class ProxyFilter
extends Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	ProxyFilter.State

Field Summary

Fields

Modifier and Type	Field	Description
private InetSocketAddress	originalDestinationAddress
private final ConnectorConfiguration.ProxyConfiguration	proxyConfiguration
private final ProxyDigestAuthenticator	proxyDigestAuthenticator
private ProxyFilter.State	state

Fields inherited from class org.glassfish.jersey.jdk.connector.internal.Filter

downstreamFilter, upstreamFilter

Constructor Summary

Constructors

Constructor	Description
ProxyFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter, ConnectorConfiguration.ProxyConfiguration proxyConfiguration)	Constructor.

Method Summary

Modifier and Type	Method	Description
(package private) void	connect(SocketAddress address, Filter<?,?,HttpRequest,HttpResponse> upstreamFilter)	Initiate connect.
private HttpRequest	createAuthenticatingRequest(HttpResponse httpResponse)
private HttpRequest	createConnectRequest()
private String	getOriginalDestinationUri()
private void	handleError(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.

Methods inherited from class org.glassfish.jersey.jdk.connector.internal.Filter

close, handleConnect, onConnectionClosed, onError, onRead, onSslHandshakeCompleted, processConnect, processConnectionClosed, processError, processSslHandshakeCompleted, startSsl

Methods inherited from class java.lang.Object

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

Field Details

proxyConfiguration

private final ConnectorConfiguration.ProxyConfiguration proxyConfiguration

proxyDigestAuthenticator

private final ProxyDigestAuthenticator proxyDigestAuthenticator

state

private volatile ProxyFilter.State state

originalDestinationAddress

private volatile InetSocketAddress originalDestinationAddress

Constructor Details

ProxyFilter

ProxyFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter,
 ConnectorConfiguration.ProxyConfiguration proxyConfiguration)

Constructor.

Parameters:

downstreamFilter - downstream filter. Accessible directly as Filter.downstreamFilter protected field.

Method Details

connect

void connect(SocketAddress address,
 Filter<?,?,HttpRequest,HttpResponse> upstreamFilter)

Description copied from class: Filter

Initiate connect.

If the Filter needs to do something during this phase, it must implement Filter.handleConnect(SocketAddress, Filter) method.

Overrides:

connect in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

Parameters:

address - an address where to connect (server or proxy).

upstreamFilter - a filter positioned upstream.

onConnect

void onConnect()

Description copied from class: Filter

An event listener that is called when a connection is set up. This event travels up in the filter chain.

If the Filter needs to process this event, it must implement Filter.processConnect() method.

Overrides:

onConnect in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

processRead

boolean processRead(HttpResponse httpResponse)

Description copied from class: Filter

Process Filter.onRead(Object).

Overrides:

processRead in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

Parameters:

httpResponse - read data.

Returns:

true if the data should be sent to processing to upper filter in the chain, false otherwise.

write

void write(HttpRequest data,
 CompletionHandler<HttpRequest> completionHandler)

Description copied from class: Filter

Perform write operation for this filter and invokes write method on the next filter in the filter chain.

Overrides:

write in class Filter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>

Parameters:

data - on which write operation is performed.

completionHandler - will be invoked when the write operation is completed or has failed.

handleError

private void handleError(Throwable t)

createAuthenticatingRequest

private HttpRequest createAuthenticatingRequest(HttpResponse httpResponse)
                                         throws ProxyAuthenticationException

Throws:

ProxyAuthenticationException

createConnectRequest

private HttpRequest createConnectRequest()

getOriginalDestinationUri

private String getOriginalDestinationUri()