|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use IoSession | |
---|---|
org.apache.mina.core | Common types required for users to use MINA. |
org.apache.mina.core.filterchain | |
org.apache.mina.core.future | |
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.codec.demux | Protocol codecs that helps you to implement even more complex protocols by splitting a codec into multiple sub-codecs. |
org.apache.mina.filter.codec.netty | Protocol codec which provides the integration with Netty2 messages. |
org.apache.mina.filter.codec.prefixedstring | |
org.apache.mina.filter.codec.serialization | Protocol codecs which uses Java object serilization and leads to rapid protocol implementation. |
org.apache.mina.filter.codec.statemachine | |
org.apache.mina.filter.codec.textline | A protocol codec for text-based protocols. |
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.handler.chain | A handler implementation that helps you implement sequentially layered protocols using Chains of Responsibility pattern. |
org.apache.mina.handler.demux | A handler implementation that helps you implement complex protocols by splitting messageReceived handlers into multiple sub-handlers. |
org.apache.mina.handler.multiton | Enables creating a handler per session instead of having one handler for many sessions, using Multiton pattern. |
org.apache.mina.handler.stream | |
org.apache.mina.integration.jmx | JMX (Java Management eXtension) integration. |
org.apache.mina.integration.ognl | |
org.apache.mina.transport.serial | |
org.apache.mina.transport.socket.apr | |
org.apache.mina.transport.socket.nio | Socket (TCP/IP) and Datagram (UDP/IP) support based on Java NIO (New I/O) API. |
org.apache.mina.transport.vmpipe | In-VM pipe support which removes the overhead of local loopback communication. |
Uses of IoSession in org.apache.mina.core |
---|
Methods in org.apache.mina.core with parameters of type IoSession | |
---|---|
static List<WriteFuture> |
IoUtil.broadcast(Object message,
IoSession... sessions)
Writes the specified message to the specified sessions . |
Method parameters in org.apache.mina.core with type arguments of type IoSession | |
---|---|
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Collection<IoSession> sessions)
Writes the specified message to the specified sessions . |
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Iterable<IoSession> sessions)
Writes the specified message to the specified sessions . |
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Iterator<IoSession> sessions)
Writes the specified message to the specified sessions . |
Uses of IoSession in org.apache.mina.core.filterchain |
---|
Methods in org.apache.mina.core.filterchain that return IoSession | |
---|---|
IoSession |
IoFilterChain.getSession()
Returns the parent IoSession of this chain. |
IoSession |
DefaultIoFilterChain.getSession()
|
Methods in org.apache.mina.core.filterchain with parameters of type IoSession | |
---|---|
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters IoHandler.exceptionCaught(IoSession,Throwable)
event. |
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
Throwable cause)
Forwards exceptionCaught event to next filter. |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters close() method invocation. |
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards filterClose event to next filter. |
void |
IoFilter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask)
Filters setTrafficMask(TrafficMask) method invocation. |
void |
IoFilterAdapter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask)
|
void |
IoFilter.NextFilter.filterSetTrafficMask(IoSession session,
TrafficMask trafficMask)
Forwards filterSetTrafficMask event to next filter. |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters write(Object) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards filterWrite event to next filter. |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters IoHandler.messageReceived(IoSession,Object)
event. |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
IoFilter.NextFilter.messageReceived(IoSession session,
Object message)
Forwards messageReceived event to next filter. |
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)
|
void |
IoFilter.NextFilter.messageSent(IoSession session,
WriteRequest writeRequest)
Forwards messageSent event to next filter. |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters IoHandler.sessionClosed(IoSession) event. |
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
IoFilter.NextFilter.sessionClosed(IoSession session)
Forwards sessionClosed event to next filter. |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters IoHandler.sessionCreated(IoSession) event. |
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
IoFilter.NextFilter.sessionCreated(IoSession session)
Forwards sessionCreated event to next filter. |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters IoHandler.sessionIdle(IoSession,IdleStatus)
event. |
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
void |
IoFilter.NextFilter.sessionIdle(IoSession session,
IdleStatus status)
Forwards sessionIdle event to next filter. |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters IoHandler.sessionOpened(IoSession) event. |
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
IoFilter.NextFilter.sessionOpened(IoSession session)
Forwards sessionOpened event to next filter. |
Constructors in org.apache.mina.core.filterchain with parameters of type IoSession | |
---|---|
IoFilterEvent(IoFilter.NextFilter nextFilter,
IoEventType type,
IoSession session,
Object parameter)
|
Uses of IoSession in org.apache.mina.core.future |
---|
Methods in org.apache.mina.core.future that return IoSession | |
---|---|
IoSession |
DefaultConnectFuture.getSession()
|
IoSession |
DefaultIoFuture.getSession()
Returns the IoSession which is associated with this future. |
IoSession |
IoFuture.getSession()
Returns the IoSession which is associated with this future. |
IoSession |
ConnectFuture.getSession()
Returns IoSession which is the result of connect operation. |
Methods in org.apache.mina.core.future with parameters of type IoSession | |
---|---|
static WriteFuture |
DefaultWriteFuture.newNotWrittenFuture(IoSession session,
Throwable cause)
Returns a new DefaultWriteFuture which is already marked as 'not written'. |
static WriteFuture |
DefaultWriteFuture.newWrittenFuture(IoSession session)
Returns a new DefaultWriteFuture which is already marked as 'written'. |
void |
DefaultConnectFuture.setSession(IoSession session)
|
void |
ConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for this future. |
Constructors in org.apache.mina.core.future with parameters of type IoSession | |
---|---|
DefaultCloseFuture(IoSession session)
Creates a new instance. |
|
DefaultIoFuture(IoSession session)
Creates a new instance associated with an IoSession . |
|
DefaultReadFuture(IoSession session)
Creates a new instance. |
|
DefaultWriteFuture(IoSession session)
Creates a new instance. |
Uses of IoSession in org.apache.mina.core.polling |
---|
Methods in org.apache.mina.core.polling that return IoSession | |
---|---|
IoSession |
AbstractPollingIoAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
IoSession |
AbstractPollingConnectionlessIoAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
Uses of IoSession in org.apache.mina.core.service |
---|
Classes in org.apache.mina.core.service with type parameters of type IoSession | |
---|---|
interface |
IoProcessor<T extends IoSession>
An internal interface to represent an 'I/O processor' that performs actual I/O operations for IoSession s. |
Methods in org.apache.mina.core.service that return IoSession | |
---|---|
IoSession |
IoAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
Methods in org.apache.mina.core.service that return types with arguments of type IoSession | |
---|---|
Map<Long,IoSession> |
IoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this service. |
Map<Long,IoSession> |
IoServiceListenerSupport.getManagedSessions()
|
Map<Long,IoSession> |
AbstractIoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this service. |
Methods in org.apache.mina.core.service with parameters of type IoSession | |
---|---|
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
Throwable cause)
|
void |
IoHandler.exceptionCaught(IoSession session,
Throwable cause)
Invoked when any exception is thrown by user IoHandler
implementation or by MINA. |
protected void |
AbstractIoService.finishSessionInitialization(IoSession session,
IoFuture future,
IoSessionInitializer sessionInitializer)
|
protected void |
AbstractIoConnector.finishSessionInitialization0(IoSession session,
IoFuture future)
Adds required internal attributes and IoFutureListener s
related with event notifications to the specified session
and future . |
protected void |
AbstractIoService.finishSessionInitialization0(IoSession session,
IoFuture future)
Implement this method to perform additional tasks required for session initialization. |
void |
IoServiceListenerSupport.fireSessionCreated(IoSession session)
Calls IoServiceListener.sessionCreated(IoSession) for all registered listeners. |
void |
IoServiceListenerSupport.fireSessionDestroyed(IoSession session)
Calls IoServiceListener.sessionDestroyed(IoSession) for all registered listeners. |
void |
IoHandlerAdapter.messageReceived(IoSession session,
Object message)
|
void |
IoHandler.messageReceived(IoSession session,
Object message)
Invoked when a message is received. |
void |
IoHandlerAdapter.messageSent(IoSession session,
Object message)
|
void |
IoHandler.messageSent(IoSession session,
Object message)
Invoked when a message written by write(Object) is
sent out. |
void |
IoHandlerAdapter.sessionClosed(IoSession session)
|
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed. |
void |
IoHandlerAdapter.sessionCreated(IoSession session)
|
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an IoService . |
void |
IoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created. |
void |
IoServiceListener.sessionDestroyed(IoSession session)
Invoked when a session is being destroyed by an IoService . |
void |
IoHandlerAdapter.sessionIdle(IoSession session,
IdleStatus status)
|
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related IdleStatus when a connection becomes idle. |
void |
IoHandlerAdapter.sessionOpened(IoSession session)
|
void |
IoHandler.sessionOpened(IoSession session)
Invoked when a connection has been opened. |
Uses of IoSession in org.apache.mina.core.session |
---|
Classes in org.apache.mina.core.session that implement IoSession | |
---|---|
class |
AbstractIoSession
Base implementation of IoSession . |
class |
DummySession
A dummy IoSession for unit-testing or non-network-use of
the classes that depends on IoSession . |
Methods in org.apache.mina.core.session that return IoSession | |
---|---|
IoSession |
IoEvent.getSession()
|
IoSession |
IoSessionRecycler.recycle(SocketAddress localAddress,
SocketAddress remoteAddress)
Attempts to retrieve a recycled IoSession . |
IoSession |
ExpiringSessionRecycler.recycle(SocketAddress localAddress,
SocketAddress remoteAddress)
|
Methods in org.apache.mina.core.session that return types with arguments of type IoSession | |
---|---|
IoProcessor<IoSession> |
DummySession.getProcessor()
|
Methods in org.apache.mina.core.session with parameters of type IoSession | |
---|---|
boolean |
IoSessionAttributeMap.containsAttribute(IoSession session,
Object key)
Returns true if this session contains the attribute with the specified key. |
void |
IoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session. |
Object |
IoSessionAttributeMap.getAttribute(IoSession session,
Object key,
Object defaultValue)
Returns the value of user defined attribute associated with the specified key. |
Set<Object> |
IoSessionAttributeMap.getAttributeKeys(IoSession session)
Returns the set of keys of all user-defined attributes. |
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session)
|
IoSessionAttributeMap |
IoSessionDataStructureFactory.getAttributeMap(IoSession session)
Returns an IoSessionAttributeMap which is going to be associated
with the specified session. |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.getWriteRequestQueue(IoSession session)
|
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session)
Returns an WriteRequest which is going to be associated with
the specified session. |
void |
IoSessionInitializer.initializeSession(IoSession session,
T future)
|
static void |
IdleStatusChecker.notifyIdleSession(IoSession session,
long currentTime)
Fires a IoEventType.SESSION_IDLE event if applicable for the
specified session . |
void |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new IoSession . |
void |
ExpiringSessionRecycler.put(IoSession session)
|
void |
IoSessionRecycler.remove(IoSession session)
Called when an IoSession is explicitly closed. |
void |
ExpiringSessionRecycler.remove(IoSession session)
|
Object |
IoSessionAttributeMap.removeAttribute(IoSession session,
Object key)
Removes a user-defined attribute with the specified key. |
boolean |
IoSessionAttributeMap.removeAttribute(IoSession session,
Object key,
Object value)
Removes a user defined attribute with the specified key if the current attribute value is equal to the specified value. |
boolean |
IoSessionAttributeMap.replaceAttribute(IoSession session,
Object key,
Object oldValue,
Object newValue)
Replaces a user defined attribute with the specified key if the value of the attribute is equals to the specified old value. |
Object |
IoSessionAttributeMap.setAttribute(IoSession session,
Object key,
Object value)
Sets a user-defined attribute. |
Object |
IoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
Object key,
Object value)
Sets a user defined attribute if the attribute with the specified key is not set yet. |
Method parameters in org.apache.mina.core.session with type arguments of type IoSession | |
---|---|
static void |
IdleStatusChecker.notifyIdleness(Iterator<? extends IoSession> sessions,
long currentTime)
Fires a IoEventType.SESSION_IDLE event to any applicable
sessions in the specified collection. |
Constructors in org.apache.mina.core.session with parameters of type IoSession | |
---|---|
IoEvent(IoEventType type,
IoSession session,
Object parameter)
|
Uses of IoSession in org.apache.mina.core.write |
---|
Methods in org.apache.mina.core.write with parameters of type IoSession | |
---|---|
void |
WriteRequestQueue.clear(IoSession session)
|
void |
WriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session. |
boolean |
WriteRequestQueue.isEmpty(IoSession session)
|
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
|
WriteRequest |
WriteRequestQueue.poll(IoSession session)
|
Uses of IoSession in org.apache.mina.filter.buffer |
---|
Methods in org.apache.mina.filter.buffer with parameters of type IoSession | |
---|---|
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 write(Object) method invocation. |
void |
BufferedWriteFilter.flush(IoSession session)
Flushes the buffered data. |
void |
BufferedWriteFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters IoHandler.sessionClosed(IoSession) event. |
Constructor parameters in org.apache.mina.filter.buffer with type arguments of type IoSession | |
---|---|
BufferedWriteFilter(int bufferSize,
LazyInitializedCacheMap<IoSession,IoBuffer> buffersMap)
Constructor which sets buffer size to bufferSize . |
Uses of IoSession in org.apache.mina.filter.codec |
---|
Classes in org.apache.mina.filter.codec that implement IoSession | |
---|---|
class |
ProtocolCodecSession
A virtual IoSession that provides ProtocolEncoderOutput
and ProtocolDecoderOutput . |
Methods in org.apache.mina.filter.codec with parameters of type IoSession | |
---|---|
void |
CumulativeProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Cumulates content of in into internal buffer and forwards decoding request to CumulativeProtocolDecoder.doDecode(IoSession, IoBuffer, ProtocolDecoderOutput) . |
void |
ProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects. |
void |
SynchronizedProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
ProtocolDecoderAdapter.dispose(IoSession session)
Override this method to dispose all resources related with this decoder. |
void |
CumulativeProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session. |
void |
SynchronizedProtocolEncoder.dispose(IoSession session)
|
void |
ProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder. |
void |
ProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder. |
void |
ProtocolEncoderAdapter.dispose(IoSession session)
Override this method dispose all resources related with this encoder. |
void |
SynchronizedProtocolDecoder.dispose(IoSession session)
|
protected abstract boolean |
CumulativeProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and decode its content into message(s). |
void |
SynchronizedProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
void |
ProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data. |
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ProtocolDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection. |
void |
ProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed. |
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
|
ProtocolDecoder |
ProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolDecoder |
ProtocolCodecFilter.getDecoder(IoSession session)
|
ProtocolEncoder |
ProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
ProtocolEncoder |
ProtocolCodecFilter.getEncoder(IoSession session)
|
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
Uses of IoSession in org.apache.mina.filter.codec.demux |
---|
Methods in org.apache.mina.filter.codec.demux with parameters of type IoSession | |
---|---|
MessageDecoderResult |
MessageDecoder.decodable(IoSession session,
IoBuffer in)
Checks the specified buffer is decodable by this decoder. |
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects. |
void |
DemuxingProtocolDecoder.dispose(IoSession session)
|
void |
DemuxingProtocolEncoder.dispose(IoSession session)
|
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
DemuxingProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
void |
MessageEncoder.encode(IoSession session,
T message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data. |
void |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed while this decoder was parsing the data. |
void |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
|
void |
MessageDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection. |
ProtocolDecoder |
DemuxingProtocolCodecFactory.getDecoder(IoSession session)
|
ProtocolEncoder |
DemuxingProtocolCodecFactory.getEncoder(IoSession session)
|
Uses of IoSession in org.apache.mina.filter.codec.netty |
---|
Methods in org.apache.mina.filter.codec.netty with parameters of type IoSession | |
---|---|
void |
NettyDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
NettyEncoder.dispose(IoSession session)
|
void |
NettyEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
ProtocolDecoder |
NettyCodecFactory.getDecoder(IoSession session)
|
ProtocolEncoder |
NettyCodecFactory.getEncoder(IoSession session)
|
Uses of IoSession in org.apache.mina.filter.codec.prefixedstring |
---|
Methods in org.apache.mina.filter.codec.prefixedstring with parameters of type IoSession | |
---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
PrefixedStringEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
ProtocolDecoder |
PrefixedStringCodecFactory.getDecoder(IoSession session)
|
ProtocolEncoder |
PrefixedStringCodecFactory.getEncoder(IoSession session)
|
Uses of IoSession in org.apache.mina.filter.codec.serialization |
---|
Methods in org.apache.mina.filter.codec.serialization with parameters of type IoSession | |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
ObjectSerializationEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
ProtocolDecoder |
ObjectSerializationCodecFactory.getDecoder(IoSession session)
|
ProtocolEncoder |
ObjectSerializationCodecFactory.getEncoder(IoSession session)
|
Uses of IoSession in org.apache.mina.filter.codec.statemachine |
---|
Methods in org.apache.mina.filter.codec.statemachine with parameters of type IoSession | |
---|---|
void |
DecodingStateProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects. |
void |
DecodingStateProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder. |
void |
DecodingStateProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed. |
Uses of IoSession in org.apache.mina.filter.codec.textline |
---|
Methods in org.apache.mina.filter.codec.textline with parameters of type IoSession | |
---|---|
void |
TextLineDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
|
void |
TextLineDecoder.dispose(IoSession session)
|
void |
TextLineEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
|
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
|
ProtocolDecoder |
TextLineCodecFactory.getDecoder(IoSession session)
|
ProtocolEncoder |
TextLineCodecFactory.getEncoder(IoSession session)
|
protected void |
TextLineDecoder.writeText(IoSession session,
String text,
ProtocolDecoderOutput out)
By default, this method propagates the decoded line of text to ProtocolDecoderOutput#write(Object) . |
Uses of IoSession in org.apache.mina.filter.compression |
---|
Methods in org.apache.mina.filter.compression with parameters of type IoSession | |
---|---|
protected Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
Uses of IoSession in org.apache.mina.filter.errorgenerating |
---|
Methods in org.apache.mina.filter.errorgenerating with parameters of type IoSession | |
---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ErrorGeneratingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
Uses of IoSession in org.apache.mina.filter.executor |
---|
Methods in org.apache.mina.filter.executor with parameters of type IoSession | |
---|---|
void |
ExecutorFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
void |
ExecutorFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ExecutorFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ExecutorFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ExecutorFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ExecutorFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
void |
ExecutorFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
|
Uses of IoSession in org.apache.mina.filter.firewall |
---|
Methods in org.apache.mina.filter.firewall with parameters of type IoSession | |
---|---|
protected boolean |
ConnectionThrottleFilter.isConnectionOk(IoSession session)
Method responsible for deciding if a connection is OK to continue |
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)
|
Uses of IoSession in org.apache.mina.filter.keepalive |
---|
Methods in org.apache.mina.filter.keepalive with parameters of type IoSession | |
---|---|
Object |
KeepAliveMessageFactory.getRequest(IoSession session)
Returns a (new) keep-alive request message. |
Object |
KeepAliveMessageFactory.getResponse(IoSession session,
Object request)
Returns a (new) response message for the specified keep-alive request. |
boolean |
KeepAliveMessageFactory.isRequest(IoSession session,
Object message)
Returns true if and only if the specified message is a keep-alive request message. |
boolean |
KeepAliveMessageFactory.isResponse(IoSession session,
Object message)
Returns true if and only if the specified message is a keep-alive response message; |
void |
KeepAliveRequestTimeoutHandler.keepAliveRequestTimedOut(KeepAliveFilter filter,
IoSession session)
Invoked when KeepAliveFilter couldn't receive the response for
the sent keep alive message. |
void |
KeepAliveFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
Uses of IoSession in org.apache.mina.filter.logging |
---|
Methods in org.apache.mina.filter.logging with parameters of type IoSession | |
---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
protected void |
MdcInjectionFilter.fillContext(IoSession session,
Map<String,String> context)
write key properties of the session to the Mapped Diagnostic Context sub-classes could override this method to map more/other attributes |
static String |
MdcInjectionFilter.getProperty(IoSession session,
String key)
|
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
static void |
MdcInjectionFilter.removeProperty(IoSession session,
String key)
|
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)
|
static void |
MdcInjectionFilter.setProperty(IoSession session,
String key,
String value)
Add a property to the context for the given session This property will be added to the MDC for all subsequent events |
Uses of IoSession in org.apache.mina.filter.reqres |
---|
Methods in org.apache.mina.filter.reqres with parameters of type IoSession | |
---|---|
protected Map<Object,Request> |
RequestResponseFilter.createRequestStore(IoSession session)
Returns a Map which stores messageId -Request
pairs whose Response s are not received yet. |
protected Set<Request> |
RequestResponseFilter.createUnrespondedRequestStore(IoSession session)
Returns a Set which stores Request whose
Response s are not received yet. |
protected Object |
RequestResponseFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
RequestResponseFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
RequestResponseFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
Uses of IoSession in org.apache.mina.filter.ssl |
---|
Methods in org.apache.mina.filter.ssl with parameters of type IoSession | |
---|---|
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)
|
SSLSession |
SslFilter.getSslSession(IoSession session)
Returns the underlying SSLSession for the specified session. |
boolean |
SslFilter.isSslStarted(IoSession session)
Returns true if and only if the specified session is encrypted/decrypted over SSL/TLS currently. |
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
SslFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
boolean |
SslFilter.startSsl(IoSession session)
(Re)starts SSL session for the specified session if not started yet. |
WriteFuture |
SslFilter.stopSsl(IoSession session)
Stops the SSL session by sending TLS close_notify message to initiate TLS closure. |
Uses of IoSession in org.apache.mina.filter.statistic |
---|
Methods in org.apache.mina.filter.statistic with parameters of type IoSession | |
---|---|
void |
ProfilerTimerFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
|
Uses of IoSession in org.apache.mina.filter.stream |
---|
Methods in org.apache.mina.filter.stream with parameters of type IoSession | |
---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
Uses of IoSession in org.apache.mina.filter.util |
---|
Methods in org.apache.mina.filter.util with parameters of type IoSession | |
---|---|
protected abstract Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
|
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
void |
WriteRequestFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
|
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ReferenceCountingFilter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask)
|
void |
CommonEventFilter.filterWrite(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.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
|
void |
CommonEventFilter.messageSent(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.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ReferenceCountingFilter.sessionCreated(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 |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
|
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
|
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
|
Uses of IoSession in org.apache.mina.handler.chain |
---|
Methods in org.apache.mina.handler.chain with parameters of type IoSession | |
---|---|
void |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
Object message)
Execute a unit of processing work to be performed. |
void |
IoHandlerChain.execute(IoHandlerCommand.NextCommand next,
IoSession session,
Object message)
|
void |
IoHandlerCommand.NextCommand.execute(IoSession session,
Object message)
Forwards the request to the next IoHandlerCommand in the
IoHandlerChain . |
void |
ChainedIoHandler.messageReceived(IoSession session,
Object message)
Handles the specified messageReceived event with the IoHandlerCommand or IoHandlerChain you specified
in the constructor. |
Uses of IoSession in org.apache.mina.handler.demux |
---|
Methods in org.apache.mina.handler.demux with parameters of type IoSession | |
---|---|
void |
ExceptionHandler.exceptionCaught(IoSession session,
E cause)
Invoked when the specific type of exception is caught from the specified session . |
void |
DemuxingIoHandler.exceptionCaught(IoSession session,
Throwable cause)
|
void |
MessageHandler.handleMessage(IoSession session,
E message)
Invoked when the specific type of message is received from or sent to the specified session . |
void |
DemuxingIoHandler.messageReceived(IoSession session,
Object message)
Forwards the received events into the appropriate MessageHandler
which is registered by DemuxingIoHandler.addReceivedMessageHandler(Class, MessageHandler) . |
void |
DemuxingIoHandler.messageSent(IoSession session,
Object message)
|
Uses of IoSession in org.apache.mina.handler.multiton |
---|
Methods in org.apache.mina.handler.multiton that return IoSession | |
---|---|
protected IoSession |
SingleSessionIoHandlerAdapter.getSession()
Retrieves the session to which this handler is assigned. |
Methods in org.apache.mina.handler.multiton with parameters of type IoSession | |
---|---|
void |
SingleSessionIoHandlerDelegate.exceptionCaught(IoSession session,
Throwable cause)
Delegates the method call to the SingleSessionIoHandler.exceptionCaught(Throwable) method of the
handler assigned to this session. |
SingleSessionIoHandler |
SingleSessionIoHandlerFactory.getHandler(IoSession session)
Returns a SingleSessionIoHandler for the given session. |
void |
SingleSessionIoHandlerDelegate.messageReceived(IoSession session,
Object message)
Delegates the method call to the SingleSessionIoHandler.messageReceived(Object) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.messageSent(IoSession session,
Object message)
Delegates the method call to the SingleSessionIoHandler.messageSent(Object) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionClosed(IoSession session)
Delegates the method call to the SingleSessionIoHandler.sessionClosed() method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionCreated(IoSession session)
Creates a new instance with the factory passed to the constructor of this class. |
void |
SingleSessionIoHandlerDelegate.sessionIdle(IoSession session,
IdleStatus status)
Delegates the method call to the SingleSessionIoHandler.sessionIdle(IdleStatus) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionOpened(IoSession session)
Delegates the method call to the SingleSessionIoHandler.sessionOpened() method of the handler
assigned to this session. |
Constructors in org.apache.mina.handler.multiton with parameters of type IoSession | |
---|---|
SingleSessionIoHandlerAdapter(IoSession session)
Creates a new instance that is assigned to the passed in session. |
Uses of IoSession in org.apache.mina.handler.stream |
---|
Methods in org.apache.mina.handler.stream with parameters of type IoSession | |
---|---|
void |
StreamIoHandler.exceptionCaught(IoSession session,
Throwable cause)
Forwards caught exceptions to input stream. |
void |
StreamIoHandler.messageReceived(IoSession session,
Object buf)
Forwards read data to input stream. |
protected abstract void |
StreamIoHandler.processStreamIo(IoSession session,
InputStream in,
OutputStream out)
Implement this method to execute your stream I/O logic; please note that you must forward the process request to other thread or thread pool. |
void |
StreamIoHandler.sessionClosed(IoSession session)
Closes streams |
void |
StreamIoHandler.sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout. |
void |
StreamIoHandler.sessionOpened(IoSession session)
Initializes streams and timeout settings. |
Uses of IoSession in org.apache.mina.integration.jmx |
---|
Constructors in org.apache.mina.integration.jmx with parameters of type IoSession | |
---|---|
IoSessionMBean(IoSession source)
|
Uses of IoSession in org.apache.mina.integration.ognl |
---|
Methods in org.apache.mina.integration.ognl that return types with arguments of type IoSession | |
---|---|
Set<IoSession> |
IoSessionFinder.find(Iterable<IoSession> sessions)
Finds a Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
Method parameters in org.apache.mina.integration.ognl with type arguments of type IoSession | |
---|---|
Set<IoSession> |
IoSessionFinder.find(Iterable<IoSession> sessions)
Finds a Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
Uses of IoSession in org.apache.mina.transport.serial |
---|
Subinterfaces of IoSession in org.apache.mina.transport.serial | |
---|---|
interface |
SerialSession
An IoSession for serial communication transport. |
Uses of IoSession in org.apache.mina.transport.socket.apr |
---|
Classes in org.apache.mina.transport.socket.apr that implement IoSession | |
---|---|
class |
AprSession
An abstract IoSession serving of base for APR based sessions. |
Uses of IoSession in org.apache.mina.transport.socket.nio |
---|
Classes in org.apache.mina.transport.socket.nio that implement IoSession | |
---|---|
class |
NioSession
An IoSession which is managed by the NIO transport. |
Uses of IoSession in org.apache.mina.transport.vmpipe |
---|
Methods in org.apache.mina.transport.vmpipe that return IoSession | |
---|---|
IoSession |
VmPipeAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |