Package | Description |
---|---|
org.apache.mina.core.filterchain | |
org.apache.mina.core.polling |
Base class for implementing transport based on active polling strategies like NIO select call,
or any API based on I/O polling system calls (epoll, poll, select, kqueue, etc).
|
org.apache.mina.core.service | |
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.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 | |
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java NIO (New I/O) API.
|
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)
Fires a
IoSession.write(Object) event. |
void |
IoFilterChain.fireMessageSent(WriteRequest request)
Fires a
IoHandler.messageSent(IoSession, Object) event. |
void |
DefaultIoFilterChain.fireMessageSent(WriteRequest request)
Fires a
IoHandler.messageSent(IoSession, Object) event. |
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 |
---|---|
void |
AbstractPollingIoProcessor.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session . |
Modifier and Type | Method and Description |
---|---|
void |
SimpleIoProcessorPool.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session . |
void |
IoProcessor.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session . |
Modifier and Type | Field and Description |
---|---|
static WriteRequest |
AbstractIoSession.CLOSE_REQUEST
An internal write request object that triggers session close.
|
static WriteRequest |
AbstractIoSession.MESSAGE_SENT_REQUEST
An internal write request object that triggers message sent events.
|
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)
Decrease the counters of written messages and written bytes when a message has been written
|
void |
AbstractIoSession.increaseWrittenMessages(WriteRequest request,
long currentTime)
Increase the number of written messages
|
void |
IoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
Associate the current write request with the session
|
void |
AbstractIoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
Associate the current write request with the session
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultWriteRequest
The default implementation of
WriteRequest . |
Modifier and Type | Method and Description |
---|---|
WriteRequest |
WriteRequest.getOriginalRequest() |
WriteRequest |
DefaultWriteRequest.getOriginalRequest() |
WriteRequest |
WriteException.getRequest() |
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
Modifier and Type | Method and Description |
---|---|
List<WriteRequest> |
WriteException.getRequests() |
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)
Create a new NothingWrittenException instance
|
NothingWrittenException(WriteRequest request,
String message)
Create a new NothingWrittenException instance
|
NothingWrittenException(WriteRequest request,
String message,
Throwable cause)
Create a new NothingWrittenException instance
|
NothingWrittenException(WriteRequest request,
Throwable cause)
Create a new NothingWrittenException instance
|
WriteException(WriteRequest request)
Creates a new WriteException instance.
|
WriteException(WriteRequest request,
String message)
Creates a new WriteException instance.
|
WriteException(WriteRequest request,
String message,
Throwable cause)
Creates a new WriteException instance.
|
WriteException(WriteRequest request,
Throwable cause)
Creates a new WriteException instance.
|
WriteTimeoutException(WriteRequest request)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(WriteRequest request,
String message)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(WriteRequest request,
String message,
Throwable cause)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(WriteRequest request,
Throwable cause)
Create a new WriteTimeoutException instance
|
WriteToClosedSessionException(WriteRequest request)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(WriteRequest request,
String message)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(WriteRequest request,
String message,
Throwable cause)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(WriteRequest request,
Throwable cause)
Create a new WriteToClosedSessionException instance
|
Constructor and Description |
---|
NothingWrittenException(Collection<WriteRequest> requests)
Create a new NothingWrittenException instance
|
NothingWrittenException(Collection<WriteRequest> requests,
String message)
Create a new NothingWrittenException instance
|
NothingWrittenException(Collection<WriteRequest> requests,
String message,
Throwable cause)
Create a new NothingWrittenException instance
|
NothingWrittenException(Collection<WriteRequest> requests,
Throwable cause)
Create a new NothingWrittenException instance
|
WriteException(Collection<WriteRequest> requests)
Creates a new WriteException instance.
|
WriteException(Collection<WriteRequest> requests,
String message)
Creates a new WriteException instance.
|
WriteException(Collection<WriteRequest> requests,
String message,
Throwable cause)
Creates a new WriteException instance.
|
WriteException(Collection<WriteRequest> requests,
Throwable cause)
Creates a new WriteException instance.
|
WriteTimeoutException(Collection<WriteRequest> requests)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(Collection<WriteRequest> requests,
String message)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(Collection<WriteRequest> requests,
String message,
Throwable cause)
Create a new WriteTimeoutException instance
|
WriteTimeoutException(Collection<WriteRequest> requests,
Throwable cause)
Create a new WriteTimeoutException instance
|
WriteToClosedSessionException(Collection<WriteRequest> requests)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(Collection<WriteRequest> requests,
String message)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(Collection<WriteRequest> requests,
String message,
Throwable cause)
Create a new WriteToClosedSessionException instance
|
WriteToClosedSessionException(Collection<WriteRequest> requests,
Throwable cause)
Create a new WriteToClosedSessionException instance
|
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)
Filters
IoSession.write(Object) method invocation. |
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
Modifier and Type | Method and Description |
---|---|
protected Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
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)
Filters
IoSession.write(Object) method invocation. |
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)
Filters
IoHandler.messageSent(IoSession,Object) event. |
Modifier and Type | Method and Description |
---|---|
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
Modifier and Type | Method and Description |
---|---|
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
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)
Filters
IoSession.write(Object) method invocation. |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
Modifier and Type | Method and Description |
---|---|
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
NioDatagramAcceptor.write(NioSession session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session . |
Copyright © 2004–2021 Apache MINA Project. All rights reserved.