All Classes and Interfaces
Class
Description
AbstractAuthLogicHandler.java - Abstract class that handles an authentication
mechanism logic.
Abstract class that implements
ByteArray.The Datagram transport session configuration.
AbstractHttpLogicHandler.java - Base class for HTTP proxy
AbstractProxyLogicHandler implementations.A base implementation of
IoAcceptor.A
IoFutureA base implementation of
IoBuffer.A base implementation of
IoConnector.Base implementation of
IoServices.A
IoFuture dedicated class forBase implementation of
IoSession.A base implementation of
IoSessionConfig.A base class for implementing transport using a polling strategy.
A base class for implementing client transport using a polling strategy.
An abstract implementation of
IoProcessor which helps transport
developers to write an IoProcessor easily.An abstract bi-directional
PropertyEditor.A
ProtocolDecoderOutput based on queue.A
ProtocolEncoderOutput based on queue.AbstractProxyIoHandler.java -
IoHandler that intercepts events until handshake is complete.AbstractProxyLogicHandler.java - Helper class to handle proxy handshaking logic.
Event wrapper class for enqueued events.
Abstract
SelfTransition implementation.The TCP transport session configuration.
AbstractSocksLogicHandler.java - Base class for SOCKS
AbstractProxyLogicHandler
implementations.Abstract
StateContext which uses a Map to store the
attributes.Abstract
StateContextLookup implementation.Filter implementation which makes it possible to write Stream
objects directly using
IoSession.write(Object).Abstract
Transition implementation.Thrown by the constructors in
MethodTransition if there are several
methods with the specifed name in the target object's class.An
IoSession for APR UDP datagram based session.The class in charge of processing socket level IO events for the
AprSocketConnectorInternal singleton used for initializing correctly the APR native library
and the associated root memory pool.
An abstract
IoSession serving of base for APR based sessions.IoAcceptor for APR based socket transport (TCP/IP).IoConnector for APR based socket transport (TCP/IP).An
IoSession for APR TCP socket based session.A
PropertyEditor which converts a String into
a one-dimensional array and vice versa.An utility class for Array manipulations.
Creates a Key from a class name and an attribute name.
Finds currently available server ports.
Provides Base64 encoding and decoding as defined by RFC 2045.
A
IoFilter which blocks connections from blacklisted remote
address.Bogus
TrustManagerFactory which creates
X509TrustManager trusting everything.Exception used internally by
StateControl.Exception used internally by
StateControl.Exception used internally by
StateControl.Exception used internally by
StateControl.The base exception of the exceptions thrown by the methods in the
StateControl class.A
ByteArray backed by a IoBuffer.A
RuntimeException which is thrown when the data the IoBuffer
contains is corrupt.An
IoFilter implementation used to buffer outgoing WriteRequest almost
like what BufferedOutputStream does.Represents a sequence of bytes that can be read or written directly or
through a cursor.
Provides relocatable, relative access to the underlying array.
A factory for
ByteArrays.A linked list that stores
ByteArrays and maintains several useful invariants.Creates
ByteArrays, using a pool to reduce allocation where possible.ByteUtilities.java - Byte manipulation functions.
An
IoBufferAllocator that caches the buffers which are likely to
be reused during auto-expansion of the buffers.A unbounded circular queue based on array.
An
IoFuture for asynchronous close requests.Extend this class when you want to create a filter that
wraps the same logic around all 11 IoEvents
A ByteArray composed of other ByteArrays.
Allows for efficient detection of component boundaries when using a cursor.
Provides common functionality between the
CompositeByteArrayRelativeReader and
CompositeByteArrayRelativeWriter.Provides restricted, relative, read-only access to the bytes in a
CompositeByteArray.Provides restricted, relative, write-only access to the bytes in a
CompositeByteArray.Expands the supplied
CompositeByteArray by the number of
bytes provided in the constructorAn object that knows how to expand a
CompositeByteArray.An object that knows how to flush a
ByteArray.No-op expander.
A
ConcurrentHashMap-backed Set.An
IoFuture for asynchronous connect requests.A
IoFilter which blocks connections from connecting
at a rate faster than the specified interval.DecodingState which consumes all bytes until a CRLF
has been encountered.DecodingState which consumes all bytes until a fixed (ASCII)
character is reached.DecodingState which consumes all received bytes until the session is
closed.DecodingState which consumes all bytes until a space (0x20) or tab
(0x09) character is reached.DecodingState which consumes all bytes until a fixed (ASCII)
character is reached.A thread-safe version of
Map in which all operations that change the
Map are implemented by making a new copy of the underlying Map.DecodingState which decodes a single CRLF.A
ProtocolDecoder that cumulates the content of received buffers to a
cumulative buffer to help users implement decoders.A Thread Factory that creates Daemon threads
IoAcceptor for datagram transport (UDP/IP).IoConnector for datagram transport (UDP/IP).An
IoSessionConfig for datagram transport type.An utility class for Dates manipulations
The HTTP decoder states
Represents a state in a decoder state machine used by
DecodingStateMachine.Abstract base class for decoder state machines.
ProtocolDecoder which uses a DecodingState to decode data.A default implementation of
CloseFuture.A default implementation of
ConnectFuture.A default implementation of
DatagramSessionConfig.Default
EventFactory implementation.A default
ExceptionMonitor implementation that logs uncaught
exceptions using Logger.Manage a File to be sent to a remote host.
The default implementation for the HTTP response element.
A default
IoEventSizeEstimator implementation.A default implementation of
IoFilterChain that provides
all operations for developers who want to implement their own
transport layer once used with AbstractIoSession.The default implementation of
IoFilterChainBuilder which is useful
in most cases.The default
IoSessionDataStructureFactory implementation
that creates a new HashMap-based IoSessionAttributeMap
instance and a new synchronized ConcurrentLinkedQueue instance per
IoSession.A default implementation of
WriteFuture.A default implementation of
SocketSessionConfig.Default
StateContext implementation.StateContextFactory which creates DefaultStateContext
objects.A default immutable implementation of
TransportMetadata.A default implementation of
VmPipeSessionConfig.A default implementation of
WriteFuture.The default implementation of
WriteRequest.A convenience
ProtocolCodecFactory that provides DemuxingProtocolEncoder
and DemuxingProtocolDecoder as a pair.A composite
ProtocolDecoder that demultiplexes incoming IoBuffer
decoding requests into an appropriate MessageDecoder.A composite
ProtocolEncoder that demultiplexes incoming message
encoding requests into an appropriate MessageEncoder.DigestUtilities.java - A class supporting the HTTP DIGEST authentication (see RFC 2617).
An
IoFilter implementation generating random bytes and PDU modification in
your communication streams.Represents an event which typically corresponds to a method call on a proxy.
Intercepts the
Event arguments before the Event is passed
to the StateMachine and allows for the arguments to be modified.Used by
StateMachineProxyBuilder to create Event objects when
methods are invoked on the proxy.A handler interface that
DemuxingIoHandler forwards
exceptionCaught events to.Monitors uncaught exceptions.
A filter that forwards I/O events to
Executor to enforce a certain
thread model while allowing the events per session to be processed
simultaneously.A listener for expired object events.
A map with expiration.
An
IoSessionRecycler with sessions that time out on inactivity.Manage a File to be sent to a remote host.
Indicates the region of a file to be sent to the remote host.
Filter implementation that converts a
FileRegion to IoBuffer
objects and writes those buffers to the next filter.An empty interface that each Filter that is going to send a specific event must implement.
DecodingState which consumes all received bytes until a configured
number of read bytes has been reached.HttpAuthenticationMethods.java - Enumerates all known http authentication methods.
HttpBasicAuthLogicHandler.java - HTTP Basic authentication mechanism logic handler.
The HTTP client codec
An HTTP decoder
An encoder for the HTTP client
The HTTP content chunk object
HttpDigestAuthLogicHandler.java - HTTP Digest authentication mechanism logic handler.
The HTTP end of content element
An HTTP message, the ancestor of HTTP request & response.
The HTTP method, one of GET, HEAD, POST, PUT, DELETE, OPTIONS, TRACE, CONNECT
HttpNoAuthLogicHandler.java - HTTP 'no auth' mechanism logic handler.
HttpNTLMAuthLogicHandler.java - HTTP NTLM authentication mechanism logic handler.
HttpProxyConstants.java - HTTP Proxy constants.
HttpProxyRequest.java - Wrapper class for HTTP requests.
HttpProxyResponse.java - Wrapper class for HTTP requests.
An HTTP request element
A HTTP Request implementation
An HTTP response to an HTTP request
The HTTP server codec
The HTTP decoder
An encoder for the HTTP server
HttpSmartProxyHandler.java - HTTP proxy handler that automatically handles forwarding a request
to the appropriate authentication mechanism logic handler.
An
Enumeration of all known HTTP status codes.The HTTP verb.
Type safe enumeration representing HTTP protocol version
An
IdentityHashMap-backed Set.Detects idle sessions and fires
sessionIdle events to them.DecodingState which decodes int values in big-endian
order (high bytes come first).Provides absolute read access to a sequence of bytes.
Provides absolute write access to a sequence of bytes.
Accepts incoming connection, communicates with clients, and fires events to
IoHandlers.A byte buffer used by MINA applications.
Allocates
IoBuffers and manages them.IoBufferDecoder.java - Handles an
IoBuffer decoder which supports
two methods :
- dynamic delimiter decoding
- fixed length content readingProvides utility methods to dump an
IoBuffer into a hex formatted
string.An
LazyInitializer implementation that initializes an
IoBuffer only when needed.A
IoBuffer that wraps a buffer and proxies any operations to it.Connects to endpoint, communicates with the server, and fires events to
IoHandlers.An I/O event or an I/O request that MINA provides.
Listens and filters all event queue operations occurring in
OrderedThreadPoolExecutor and UnorderedThreadPoolExecutor.Throttles incoming or outgoing events.
Estimates the amount of memory that the specified
IoEvent occupies
in the current JVM.An
Enum that represents the type of I/O events and requests.A filter which intercepts
IoHandler events like Servlet
filters.Represents the next
IoFilter in IoFilterChain.An adapter class for
IoFilter.Represents a name-filter pair that an
IoFilterChain contains.An interface that builds
IoFilterChain in predefined way
when IoSession is created.An I/O event or an I/O request that MINA provides for
IoFilters.Defines all possible MINA
IoFilter events for use in IoFilterTransition
annotations.A
RuntimeException which is thrown when IoFilter.init()
or IoFilter.onPostAdd(IoFilterChain, String, org.apache.mina.core.filterchain.IoFilter.NextFilter)
failed.Annotation used on methods to indicate that the method handles a specific
kind of
IoFilterEvents event when in a specific state.Annotation used to annotate a method with several
IoFilterTransitions.Represents the completion of an asynchronous I/O operation on an
IoSession.Something interested in being notified when the completion
of an asynchronous I/O operation :
IoFuture.Handles all I/O events fired by MINA.
An adapter class for
IoHandler.A chain of
IoHandlerCommands.A
IoHandlerCommand encapsulates a unit of processing work to be
performed, whose purpose is to examine and/or modify the state of a
transaction that is represented by custom attributes provided by
IoSession.Represents an indirect reference to the next
IoHandlerCommand of
the IoHandlerChain.Defines all possible MINA
IoHandler events for use in IoHandlerTransition
annotations.Annotation used on methods to indicate that the method handles a specific
kind of
IoHandlerEvents event when in a specific state.Annotation used to annotate a method with several
IoHandlerTransitions.An internal interface to represent an 'I/O processor' that performs
actual I/O operations for
IoSessions.Provides relative read access to a sequence of bytes.
Provides relative read access to a sequence of bytes.
Listens to events related to an
IoService.A helper class which provides addition and removal of
IoServiceListeners and firing
events.A listener in charge of releasing the lock when the close has been completed
Provides usage statistics for an
AbstractIoService instance.This is a configuration for IoServiceStatistics.
A handle which represents connection between two end-points regardless of
transport types.
Stores the user-defined attributes which is provided per
IoSession.The configuration of
IoSession.Provides data structures to a newly created session.
IoSessionEvent.java - Wrapper Class for enqueued events.
IoSessionEventQueue.java - Queue that contains filtered session events
while handshake isn't done.
IoSessionEventType.java - Enumerates session event types.
A
RuntimeException that is thrown when the initialization of
an IoSession fails.Defines a callback for obtaining the
IoSession during
session initialization.An
InputStream that buffers data read from
IoHandler.messageReceived(IoSession, Object) events.An
OutputStream that forwards all write operations to
the associated IoSession.A connectionless transport can recycle existing sessions by assigning an
IoSessionRecycler to an IoService.An
IoFilter that sends a keep-alive request on
IoEventType.SESSION_IDLE and sends back the response for the
sent keep-alive request.Provides keep-alive messages to
KeepAliveFilter.A
RuntimeException which is thrown when a keep-alive response
message was not received within a certain timeout.Tells
KeepAliveFilter what to do when a keep-alive response message
was not received within a certain timeout.A factory that creates and configures a new
KeyStore instance.This map is specially useful when reads are much more frequent than writes and
if the cost of instantiating the values is high like allocating an
IoBuffer for example.An abstract class which provides semantics for an object which will be only
fully initialized when requested to.
DecodingState which skips space (0x20) and tab (0x09) characters.A delimiter which is appended to the end of a text line, such as
CR/LF.Implementation of
Formatter that generates xml in the log4j format.Logs MINA protocol events.
Defines a logging level.
This filter will inject some key IoSession properties into the Mapped Diagnostic Context (MDC)
This enum lists all the possible keys this filter will process
Decodes a certain type of messages.
An abstract
MessageDecoder implementation for those who don't need to
implement MessageDecoder.finishDecode(IoSession, ProtocolDecoderOutput)
method.A factory that creates a new instance of
MessageDecoder.Represents results from
MessageDecoder.Encodes a certain type of messages.
A factory that creates a new instance of
MessageEncoder.Thrown by
MethodTransition if the target method couldn't be invoked
or threw an exception.SelfTransition which invokes a Method.Transition which invokes a Method.IoAcceptor for datagram transport (UDP/IP).IoConnector for datagram transport (UDP/IP).An
IoSession for datagram transport (UDP/IP).Define the configuration for a Datagram based session.
A processor for incoming and outgoing data get and written on a TCP socket.
An encapsulating iterator around the
Selector.selectedKeys() or
the Selector.keys() iterator;An
IoSession which is managed by the NIO transport.IoAcceptor for socket transport (TCP/IP).Defines an iterator for the selected-key Set returned by the
selector.selectedKeys().
IoConnector for socket transport (TCP/IP).An
IoSession for socket transport (TCP/IP).A Noop filter.
Transition implementation which does nothing but change the state.RuntimeException equivalent of NoSuchMethodException.Exception thrown by
StateMachine when a transition in the state
machine references a state which doesn't exist.An exception which is thrown when one or more write requests resulted
in no actual write operation.
NTLMConstants.java - All NTLM constants.
NTLMResponses.java - Calculates the various Type 3 responses.
NTLMUtilities.java - NTLM functions used for authentication and unit testing.
A dummy
PropertyEditor for null.A
ProtocolCodecFactory that serializes and deserializes Java objects.A
ProtocolDecoder which deserializes Serializable Java
objects using IoBuffer.getObject(ClassLoader).An
ObjectOutput and OutputStream that can write the objects as
the serialized form that ObjectSerializationDecoder can decode.Annotation used on methods to indicate that the method will be executed
before entering a certain state
Annotation used on methods to indicate that the method will be executed
before existing from a certain state
A
ThreadPoolExecutor that maintains the order of IoEvents.A
ProtocolCodecFactory that performs encoding and decoding
of a Java String object using a fixed-length length prefix.A
ProtocolDecoder which decodes a String using a fixed-length length prefix.A
ProtocolEncoder which encodes a string
using a fixed-length length prefix.A
ThreadPoolExecutor that maintains the order of IoEvents
within a session (similar to OrderedThreadPoolExecutor) and allows
some sessions to be prioritized over other sessions.A class used to preserve first-in-first-out order of sessions that have equal
priority.
This class will measure the time it takes for a method in the
IoFilterAdapter class to execute.A factory that creates a new
PropertyEditor which is appropriate for
the specified object or class.An exception that is thrown when
ProtocolEncoder or
ProtocolDecoder cannot understand or failed to validate
data to process.Provides
ProtocolEncoder and ProtocolDecoder which translates
binary or protocol specific data into message object and vice versa.An
IoFilter which translates binary or protocol specific data into
message objects and vice versa using ProtocolCodecFactory,
ProtocolEncoder, or ProtocolDecoder.Decodes binary or protocol-specific data into higher-level message objects.
An abstract
ProtocolDecoder implementation for those who don't need
ProtocolDecoder.finishDecode(IoSession, ProtocolDecoderOutput) nor
ProtocolDecoder.dispose(IoSession) method.An exception that is thrown when
ProtocolDecoder
cannot understand or failed to validate the specified IoBuffer
content.Callback for
ProtocolDecoder to generate decoded messages.Encodes higher-level message objects into binary or protocol-specific data.
An abstract
ProtocolEncoder implementation for those who don't have any
resources to dispose.An exception that is thrown when
ProtocolEncoder
cannot understand or failed to validate the specified message object.Callback for
ProtocolEncoder to generate encoded messages such as
IoBuffers.ProxyAuthException.java - This class extends
SaslException and represents an
authentication failure to the proxy.ProxyConnector.java - Decorator for
SocketConnector to provide proxy
support, as suggested by MINA list discussions.ProxyFilter.java - Proxy
IoFilter.ProxyHandshakeIoBuffer.java -
IoBuffer wrapper to indicate handshake
related messages which should not be passed upstream of the ProxyFilter.ProxyIoSession.java - Class that contains all informations for the current proxy
authentication session.
ProxyIoSessionInitializer.java -
IoSessionInitializer wrapper class to inject the
ProxyIoSession object that contains all the attributes of the target connection
into the IoSession.ProxyLogicHandler.java - Interface implemented by classes containing proxy type specific logic.
ProxyRequest.java - Abstract wrapper class for proxy requests.
An
IoFuture for asynchronous read requests.A special exception that tells the
ProtocolDecoder can keep
decoding even after this exception is thrown.An
IoFilters wrapper that keeps track of the number of usages of this filter and will call init/destroy
when the filter is not in use.A unchecked version of
IOException.The interface implemented by classes which need to react on entering
a certain states.
The session state.
DecodingState which decodes short values in big-endian
order (high bytes come first).A simplistic
IoBufferAllocator which simply allocates a new
buffer every time.Creates
ByteArray backed by a heap-allocated
IoBuffer.DecodingState which decodes byte values.Deprecated.
This class is not to be used anymore
Deprecated.
This class is deprecated
Deprecated.
This class is deprecated
Deprecated.
this class is deprecated
StateContextLookup implementation which always returns the same
StateContext instance.DecodingState which skips data until canSkip(byte) returns
false.IoAcceptor for socket transport (TCP/IP).IoConnector for socket transport (TCP/IP).An
IoSessionConfig for socket transport type.Socks4LogicHandler.java - SOCKS4/SOCKS4a authentication mechanisms logic handler.
Socks5LogicHandler.java - SOCKS5 authentication mechanisms logic handler.
SocksProxyConstants.java - SOCKS proxy constants.
SocksProxyRequest.java - Wrapper class for SOCKS requests.
A factory that creates and configures a new
SSLContext.A SSL event sent by
SslFilter when the session is secured or not secured.An SSL filter that encrypts and decrypts the data exchanged in the session.
A private class used to store encrypted messages.
A message that is sent from
SslFilter when the connection became
secure or is not secure anymore.No qualifier
Annotation used to define the states in a state machine.
Represents a state in a
StateMachine.StateContext objects are used to store the current State and
any application specific attributes for a specific client of a
StateMachine.Factory which creates
StateContext instances.Lookups a
StateContext from a collection of event arguments.Allows for programmatic control of a state machines execution.
Represents a complete state machine.
Exception thrown by
StateMachineFactory when a StateMachine
could not be constructed for some reason.Creates
StateMachines by reading State,
Transition and Transitions (or equivalent) and SelfTransition annotations from one or more arbitrary
objects.Used to create proxies which will forward all method calls on them to a
StateMachine.A
IoHandler that adapts asynchronous MINA events to stream I/O.Filter implementation which makes it possible to write
InputStream
objects directly using IoSession.write(Object).A dummy
PropertyEditor for a String.StringUtilities.java - Various methods to handle strings.
A IP subnet using the CIDR notation.
A
ProtocolDecoder implementation which decorates an existing decoder
to be thread-safe.A
ProtocolEncoder implementation which decorates an existing encoder
to be thread-safe.A decorator that makes the specified
Queue thread-safe.A
ProtocolCodecFactory that performs encoding and decoding between
a text line data and a Java string object.A
ProtocolDecoder which decodes a text line into a string.A
ProtocolEncoder which encodes a string into a text line
which ends with the delimiter.Utility class for working with xml data
Implementation is heavily based on org.apache.log4j.helpers.Transform
Annotation used on methods to indicate that the method handles a specific
kind of event when in a specific state.
The interface implemented by classes which need to react on transitions
between states.
Annotation used to mark other annotations as being transition annotations.
Annotation used to annotate a method with several
Transitions.Provides meta-information that describes an
IoService.Thrown when an
Event passed to a state machine couldn't be handled.An exception that is thrown when the type of the message cannot be determined.
A
ThreadPoolExecutor that does not maintain the order of IoEvents.TODO Add documentation
Binds the specified
IoHandler to the specified
VmPipeAddress.A
SocketAddress which represents in-VM pipe port number.Connects to
IoHandlers which is bound on the specified
VmPipeAddress.TODO Add documentation
A
IoSession for in-VM transport (VM_PIPE).An
IoSessionConfig for vmpipe transport type.An exception which is thrown when one or more write operations failed.
An
IoFuture for asynchronous write requests.Represents write request fired by
IoSession.write(Object).Attaches an
IoEventQueueHandler to an IoSession's
WriteRequest queue to provide accurate write queue status tracking.Stores
WriteRequests which are queued to an IoSession.An exception which is thrown when write buffer is not flushed for
IoSessionConfig.getWriteTimeout() seconds.An exception which is thrown when one or more write operations were
attempted on a closed session.
A helper class for interfacing with the JZlib library.