Package | Description |
---|---|
org.apache.mina.core.filterchain | |
org.apache.mina.core.session | |
org.apache.mina.core.write | |
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.reqres | |
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.proxy | |
org.apache.mina.proxy.filter |
Modifier and Type | Method and Description |
---|---|
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards filterWrite event to next filter.
|
void |
IoFilterChain.fireFilterWrite(WriteRequest writeRequest)
Fires a
IoSession.write(Object) event. |
void |
DefaultIoFilterChain.fireFilterWrite(WriteRequest writeRequest) |
void |
IoFilterChain.fireMessageSent(WriteRequest request)
Fires a
IoHandler#messageSent(IoSession) event. |
void |
DefaultIoFilterChain.fireMessageSent(WriteRequest request) |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object)
event. |
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object)
event. |
void |
IoFilter.NextFilter.messageSent(IoSession session,
WriteRequest writeRequest)
Forwards messageSent event to next filter.
|
Modifier and Type | Method and Description |
---|---|
WriteRequest |
IoSession.getCurrentWriteRequest()
Returns the
WriteRequest which is being processed by
IoService . |
WriteRequest |
AbstractIoSession.getCurrentWriteRequest()
Returns the
WriteRequest which is being processed by
IoService . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractIoSession.decreaseScheduledBytesAndMessages(WriteRequest request)
TODO Add method documentation
|
void |
AbstractIoSession.increaseWrittenMessages(WriteRequest request,
long currentTime)
TODO Add method documentation
|
void |
IoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
TODO setWriteRequestQueue.
|
void |
AbstractIoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
TODO setWriteRequestQueue.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultWriteRequest
The default implementation of
WriteRequest . |
class |
WriteRequestWrapper
A wrapper for an existing
WriteRequest . |
Modifier and Type | Method and Description |
---|---|
WriteRequest |
WriteRequest.getOriginalRequest()
Returns the
WriteRequest which was requested originally,
which is not transformed by any IoFilter . |
WriteRequest |
DefaultWriteRequest.getOriginalRequest() |
WriteRequest |
WriteRequestWrapper.getOriginalRequest() |
WriteRequest |
WriteRequestWrapper.getParentRequest()
Returns the wrapped request object.
|
WriteRequest |
WriteException.getRequest()
Returns the firstly failed
WriteRequest . |
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<WriteRequest> |
WriteException.getRequests()
Returns the list of the failed
WriteRequest , in the order of occurrance. |
Modifier and Type | Method and Description |
---|---|
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
Constructor and Description |
---|
NothingWrittenException(WriteRequest request) |
NothingWrittenException(WriteRequest request,
java.lang.String s) |
NothingWrittenException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
NothingWrittenException(WriteRequest request,
java.lang.Throwable cause) |
WriteException(WriteRequest request)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.String s)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.Throwable cause)
Creates a new exception.
|
WriteRequestWrapper(WriteRequest parentRequest)
Creates a new instance that wraps the specified request.
|
WriteTimeoutException(WriteRequest request) |
WriteTimeoutException(WriteRequest request,
java.lang.String s) |
WriteTimeoutException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
WriteTimeoutException(WriteRequest request,
java.lang.Throwable cause) |
WriteToClosedSessionException(WriteRequest request) |
WriteToClosedSessionException(WriteRequest request,
java.lang.String s) |
WriteToClosedSessionException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
WriteToClosedSessionException(WriteRequest request,
java.lang.Throwable cause) |
Constructor and Description |
---|
NothingWrittenException(java.util.Collection<WriteRequest> requests) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
WriteException(java.util.Collection<WriteRequest> requests)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.String s)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause)
Creates a new exception.
|
WriteTimeoutException(java.util.Collection<WriteRequest> requests) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
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.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object)
event. |
Modifier and Type | Method and Description |
---|---|
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
RequestResponseFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent 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) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.lang.Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
void |
ProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
Modifier and Type | Method and Description |
---|---|
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.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.