Package | Description |
---|---|
org.apache.mina.core.filterchain | |
org.apache.mina.example.haiku | |
org.apache.mina.example.tapedeck | |
org.apache.mina.filter.buffer | |
org.apache.mina.filter.codec |
Filter implementations that helps you to implement complex protocols via 'codec' concept.
|
org.apache.mina.filter.compression | |
org.apache.mina.filter.errorgenerating |
An IoFilter that provides flexible error generation facilities.
|
org.apache.mina.filter.executor |
IoFilters that provide flexible thread model and event queue monitoring interface.
|
org.apache.mina.filter.firewall |
Classes that implement IoFilter and provide host blocking and throttling.
|
org.apache.mina.filter.keepalive |
IoFilter that provides the ability for connections to remain open when data is not being transferred.
|
org.apache.mina.filter.logging |
Classes that implement IoFilter and provide logging of the events and data that flows through a MINA-based system.
|
org.apache.mina.filter.ssl |
Classes that implement IoFilter and provide Secure Sockets Layer functionality.
|
org.apache.mina.filter.statistic |
Classes that implement IoFilter and provide the ability for filters to be timed on their performance.
|
org.apache.mina.filter.stream |
Stream based IoFilter implementation.
|
org.apache.mina.filter.util |
Utility classes for the MINA filtering portion of the library.
|
org.apache.mina.http | |
org.apache.mina.proxy | |
org.apache.mina.proxy.event | |
org.apache.mina.proxy.filter | |
org.apache.mina.proxy.handlers.http | |
org.apache.mina.proxy.handlers.http.basic | |
org.apache.mina.proxy.handlers.http.digest | |
org.apache.mina.proxy.handlers.http.ntlm | |
org.apache.mina.proxy.handlers.socks |
Modifier and Type | Method and Description |
---|---|
IoFilter.NextFilter |
IoFilterEvent.getNextFilter() |
IoFilter.NextFilter |
IoFilterChain.Entry.getNextFilter() |
IoFilter.NextFilter |
IoFilterChain.getNextFilter(Class<? extends IoFilter> filterType)
Returns the
IoFilter.NextFilter of the specified filterType
in this chain. |
IoFilter.NextFilter |
DefaultIoFilterChain.getNextFilter(Class<? extends IoFilter> filterType) |
IoFilter.NextFilter |
IoFilterChain.getNextFilter(IoFilter filter)
Returns the
IoFilter.NextFilter of the specified IoFilter
in this chain. |
IoFilter.NextFilter |
DefaultIoFilterChain.getNextFilter(IoFilter filter) |
IoFilter.NextFilter |
IoFilterChain.getNextFilter(String name)
Returns the
IoFilter.NextFilter of the IoFilter with the
specified name in this chain. |
IoFilter.NextFilter |
DefaultIoFilterChain.getNextFilter(String name) |
Modifier and Type | Method and Description |
---|---|
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoSession.close(boolean) method invocation. |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoSession.close(boolean) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilterAdapter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilterAdapter.onPostAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is added to the specified parent.
|
void |
IoFilter.onPostAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is added to the specified parent.
|
void |
IoFilterAdapter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is removed from the specified parent.
|
void |
IoFilter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is removed from the specified parent.
|
void |
IoFilterAdapter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is added to the specified parent.
|
void |
IoFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is added to the specified parent.
|
void |
IoFilterAdapter.onPreRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is removed from the specified parent.
|
void |
IoFilter.onPreRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is removed from the specified parent.
|
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
Constructor and Description |
---|
IoFilterEvent(IoFilter.NextFilter nextFilter,
IoEventType type,
IoSession session,
Object parameter) |
Modifier and Type | Method and Description |
---|---|
void |
ToHaikuIoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
Modifier and Type | Method and Description |
---|---|
void |
AuthenticationHandler.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
AuthenticationHandler.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
AuthenticationHandler.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AuthenticationHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
AuthenticationHandler.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AuthenticationHandler.password(org.apache.mina.example.tapedeck.AuthenticationHandler.AuthenticationContext context,
IoFilter.NextFilter nextFilter,
IoSession session,
PasswordCommand cmd) |
void |
AuthenticationHandler.sendAuthRequest(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
AuthenticationHandler.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
AuthenticationHandler.user(org.apache.mina.example.tapedeck.AuthenticationHandler.AuthenticationContext context,
IoFilter.NextFilter nextFilter,
IoSession session,
UserCommand cmd) |
Modifier and Type | Method and Description |
---|---|
void |
BufferedWriteFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
BufferedWriteFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolDecoderOutput.flush(IoFilter.NextFilter nextFilter,
IoSession session)
Flushes all messages you wrote via
ProtocolDecoderOutput.write(Object) to
the next filter. |
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Process the incoming message, calling the session decoder.
|
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ProtocolCodecFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
protected Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
CompressionFilter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
CompressionFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
Modifier and Type | Method and Description |
---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ErrorGeneratingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
ExecutorFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoSession.close(boolean) method invocation. |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
ExecutorFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
ExecutorFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is added to the specified parent.
|
void |
ExecutorFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
ExecutorFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
ExecutorFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
void |
BlacklistFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
BlacklistFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ConnectionThrottleFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
KeepAliveFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
KeepAliveFilter.onPostAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is added to the specified parent.
|
void |
KeepAliveFilter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked after this filter is removed from the specified parent.
|
void |
KeepAliveFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Invoked before this filter is added to the specified parent.
|
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
Modifier and Type | Method and Description |
---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
LoggingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
SslFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
SslFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.onPostAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
SslFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter)
Executed just before the filter is added into the chain, we do :
check that we don't have a SSL filter already present
we update the next filter
we create the SSL handler helper class
and we store it into the session's Attributes
|
void |
SslFilter.onPreRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
SslFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
ProfilerTimerFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Profile a MessageReceived event.
|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent event.
|
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionClosed event.
|
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionCreated event.
|
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Profile a SessionIdle event.
|
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionOpened event.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AbstractStreamWriteFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
CommonEventFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.onPostAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ReferenceCountingFilter.onPostRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ReferenceCountingFilter.onPreAdd(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ReferenceCountingFilter.onPreRemove(IoFilterChain parent,
String name,
IoFilter.NextFilter nextFilter) |
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SessionAttributeInitializingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Puts all pre-configured attributes into the actual session attribute
map and forward the event to the next filter.
|
void |
ReferenceCountingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
HttpServerCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
HttpClientCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
ProxyLogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Called at each step of the handshake procedure.
|
void |
ProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
void |
AbstractProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
void |
ProxyLogicHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoBuffer buf)
Handle incoming data during the handshake process.
|
protected WriteFuture |
AbstractProxyLogicHandler.writeData(IoFilter.NextFilter nextFilter,
IoBuffer data)
Writes data to the proxy server.
|
Modifier and Type | Method and Description |
---|---|
IoFilter.NextFilter |
IoSessionEvent.getNextFilter() |
Constructor and Description |
---|
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Creates an instance of this class when event type is
IoSessionEventType.IDLE . |
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IoSessionEventType type)
Creates an instance of this class when event type differs from
IoSessionEventType.IDLE . |
Modifier and Type | Method and Description |
---|---|
void |
ProxyFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Called when an exception occurs in the chain.
|
void |
ProxyFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters outgoing writes, queueing them up if necessary while a handshake
is ongoing.
|
void |
ProxyFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Receives data from the remote host, passes to the handler if a handshake is in progress,
otherwise passes on transparently.
|
void |
ProxyFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.onPreAdd(IoFilterChain chain,
String name,
IoFilter.NextFilter nextFilter)
Called before the filter is added into the filter chain.
|
void |
ProxyFilter.onPreRemove(IoFilterChain chain,
String name,
IoFilter.NextFilter nextFilter)
Called when the filter is removed from the filter chain.
|
void |
ProxyFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Called when the session is created.
|
void |
ProxyFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpSmartProxyHandler.doHandshake(IoFilter.NextFilter nextFilter)
Performs the handshake processing.
|
abstract void |
AbstractAuthLogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Method called at each step of the handshaking process.
|
void |
AbstractHttpLogicHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoBuffer buf)
Handles incoming data during the handshake process.
|
void |
AbstractHttpLogicHandler.writeRequest(IoFilter.NextFilter nextFilter,
HttpProxyRequest request)
Calls writeRequest0(NextFilter, HttpProxyRequest) to write the request.
|
protected void |
AbstractAuthLogicHandler.writeRequest(IoFilter.NextFilter nextFilter,
HttpProxyRequest request)
Sends an HTTP request.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpNoAuthLogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Method called at each step of the handshaking process.
|
void |
HttpBasicAuthLogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Method called at each step of the handshaking process.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpDigestAuthLogicHandler.doHandshake(IoFilter.NextFilter nextFilter) |
Modifier and Type | Method and Description |
---|---|
void |
HttpNTLMAuthLogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Method called at each step of the handshaking process.
|
Modifier and Type | Method and Description |
---|---|
void |
Socks5LogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Performs the handshake process.
|
void |
Socks4LogicHandler.doHandshake(IoFilter.NextFilter nextFilter)
Perform the handshake.
|
protected void |
Socks5LogicHandler.handleResponse(IoFilter.NextFilter nextFilter,
IoBuffer buf,
int step)
Handle a SOCKS v5 response from the proxy server.
|
void |
Socks5LogicHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoBuffer buf)
Handles incoming data during the handshake process.
|
void |
Socks4LogicHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoBuffer buf)
Handle incoming data during the handshake process.
|
protected void |
Socks4LogicHandler.writeRequest(IoFilter.NextFilter nextFilter,
SocksProxyRequest request)
Encode a SOCKS4/SOCKS4a request and writes it to the next filter
so it can be sent to the proxy server.
|
Copyright © 2004–2016 Apache MINA Project. All rights reserved.