class Filter<UP_IN,UP_OUT,DOWN_OUT,DOWN_IN>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected Filter<DOWN_OUT,DOWN_IN,?,?> |
downstreamFilter |
protected Filter<?,?,UP_IN,UP_OUT> |
upstreamFilter |
Constructor and Description |
---|
Filter(Filter<DOWN_OUT,DOWN_IN,?,?> downstreamFilter)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
close()
Close the filter, invokes close operation on the next filter in the filter chain.
|
(package private) void |
connect(java.net.SocketAddress address,
Filter<?,?,UP_IN,UP_OUT> upstreamFilter)
Initiate connect.
|
(package private) void |
handleConnect(java.net.SocketAddress address,
Filter upstreamFilter)
Handle
connect(SocketAddress, Filter) . |
(package private) void |
onConnect()
An event listener that is called when a connection is set up.
|
(package private) void |
onConnectionClosed()
An event listener that is called when the connection is closed by the peer.
|
(package private) void |
onError(java.lang.Throwable t)
An event listener that is called when an error has occurred.
|
(package private) void |
onRead(DOWN_IN data)
An event listener that is called when some data is read.
|
(package private) void |
onSslHandshakeCompleted()
An event listener that is called, when SSL completes its handshake.
|
(package private) void |
processConnect()
Process
onConnect() . |
(package private) void |
processConnectionClosed()
Process
onConnectionClosed() . |
(package private) void |
processError(java.lang.Throwable t)
Process
onError(Throwable) . |
(package private) boolean |
processRead(DOWN_IN data)
Process
onRead(Object) . |
(package private) void |
processSslHandshakeCompleted()
Process
onSslHandshakeCompleted() . |
(package private) void |
startSsl()
Signal to turn on SSL, it is passed on in the filter chain until a filter responsible for SSL is reached.
|
(package private) void |
write(UP_IN data,
CompletionHandler<UP_IN> completionHandler)
Perform write operation for this filter and invokes write method on the next filter in the filter chain.
|
Filter(Filter<DOWN_OUT,DOWN_IN,?,?> downstreamFilter)
downstreamFilter
- downstream filter. Accessible directly as downstreamFilter
protected field.void write(UP_IN data, CompletionHandler<UP_IN> completionHandler)
data
- on which write operation is performed.completionHandler
- will be invoked when the write operation is completed or has failed.void close()
void startSsl()
void connect(java.net.SocketAddress address, Filter<?,?,UP_IN,UP_OUT> upstreamFilter)
Filter
needs to do something during this phase, it must implement handleConnect(SocketAddress, Filter)
method.address
- an address where to connect (server or proxy).upstreamFilter
- a filter positioned upstream.void onConnect()
Filter
needs to process this event, it must implement processConnect()
method.final void onRead(DOWN_IN data)
Filter
needs to process this event, it must implement onRead(Object)
()} method.
If the method returns true
, the processing will continue with upstream filters; if the method invocation
returns false
, the processing won't continue.data
- that has been read.final void onConnectionClosed()
Filter
needs to process this event, it must implement processConnectionClosed()
method.final void onSslHandshakeCompleted()
Filter
needs to process this event, it must implement processSslHandshakeCompleted()
method.final void onError(java.lang.Throwable t)
Filter
needs to process this event, it must implement processError(Throwable)
method.t
- an error that has occurred.void handleConnect(java.net.SocketAddress address, Filter upstreamFilter)
connect(SocketAddress, Filter)
.address
- an address where to connect (server or proxy).upstreamFilter
- a filter positioned upstream.connect(SocketAddress, Filter)
void processConnect()
onConnect()
.onConnect()
boolean processRead(DOWN_IN data)
onRead(Object)
.data
- read data.true
if the data should be sent to processing to upper filter in the chain, false
otherwise.onRead(Object).
void processConnectionClosed()
onConnectionClosed()
.onConnectionClosed()
void processSslHandshakeCompleted()
onSslHandshakeCompleted()
.onSslHandshakeCompleted()
void processError(java.lang.Throwable t)
onError(Throwable)
.t
- an error that has occurred.onError(Throwable)