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 class
ProxyFilter.State
-
Field Summary
Fields Modifier and Type Field Description private java.net.InetSocketAddress
originalDestinationAddress
private ConnectorConfiguration.ProxyConfiguration
proxyConfiguration
private 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
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
ProcessFilter.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
-
-
-
-
Field Detail
-
proxyConfiguration
private final ConnectorConfiguration.ProxyConfiguration proxyConfiguration
-
proxyDigestAuthenticator
private final ProxyDigestAuthenticator proxyDigestAuthenticator
-
state
private volatile ProxyFilter.State state
-
originalDestinationAddress
private volatile java.net.InetSocketAddress originalDestinationAddress
-
-
Constructor Detail
-
ProxyFilter
ProxyFilter(Filter<HttpRequest,HttpResponse,?,?> downstreamFilter, ConnectorConfiguration.ProxyConfiguration proxyConfiguration)
Constructor.- Parameters:
downstreamFilter
- downstream filter. Accessible directly asFilter.downstreamFilter
protected field.
-
-
Method Detail
-
connect
void connect(java.net.SocketAddress address, Filter<?,?,HttpRequest,HttpResponse> upstreamFilter)
Description copied from class:Filter
Initiate connect. If theFilter
needs to do something during this phase, it must implementFilter.handleConnect(SocketAddress, Filter)
method.- Overrides:
connect
in classFilter<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 theFilter
needs to process this event, it must implementFilter.processConnect()
method.- Overrides:
onConnect
in classFilter<HttpRequest,HttpResponse,HttpRequest,HttpResponse>
-
processRead
boolean processRead(HttpResponse httpResponse)
Description copied from class:Filter
ProcessFilter.onRead(Object)
.- Overrides:
processRead
in classFilter<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 classFilter<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(java.lang.Throwable t)
-
createAuthenticatingRequest
private HttpRequest createAuthenticatingRequest(HttpResponse httpResponse) throws ProxyAuthenticationException
- Throws:
ProxyAuthenticationException
-
createConnectRequest
private HttpRequest createConnectRequest()
-
getOriginalDestinationUri
private java.lang.String getOriginalDestinationUri()
-
-