All Classes and Interfaces

Class
Description
A skeletal Channel implementation.
A skeletal implementation of a buffer.
A skeletal implementation of ChannelBufferFactory.
A skeletal ChannelSink implementation.
A skeletal CodecEmbedder implementation.
 
Abstract Disk HttpData implementation
Abstract HttpData implementation
A skeletal implementation of InternalLogger.
Abstract Memory HttpData implementation
 
 
 
 
 
Abstract base class for WorkerPool implementations that create the Worker's up-front and return them in a "fair" fashion when calling AbstractNioWorkerPool.nextWorker()
 
 
Abstract base class for Oio-Worker implementations
A skeletal server-side Channel implementation.
AbstractTrafficShapingHandler allows to limit the global bandwidth (see GlobalTrafficShapingHandler) or per session bandwidth (see ChannelTrafficShapingHandler), as traffic shaping.
Attachment of ChannelHandlerContext
For simple ChannelBuffer, returns the readableBytes, else use standard DefaultObjectSizeEstimator.
The ReceiveBufferSizePredictor that automatically increases and decreases the predicted buffer size on feed back.
 
 
Attribute interface
A Web Socket echo server for running the autobahn test suite
Handles handshakes and messages
 
Utility class for ChannelBuffer that encodes and decodes to and from Base64 notation.
Decodes a Base64-encoded ChannelBuffer or US-ASCII String into a ChannelBuffer.
Enumeration of supported Base64 dialects.
Encodes a ChannelBuffer into a Base64-encoded ChannelBuffer.
A big-endian Java heap buffer.
Decodes the binary representation of a BigInteger prepended with a magic number ('F' or 0x46) and a 32-bit integer length prefix into a BigInteger instance.
Web Socket frame containing binary data
Emulates blocking read operation.
A IOException raised by BlockingReadHandler when no data was read within a certain period of time.
A helper class which initializes a Channel.
Serves the boss tasks like connecting/accepting
BossPool<E extends Boss>
A Pool that holds Boss instances
Generates a self-signed certificate using Bouncy Castle.
Emulates buffered write operation.
A NIO ByteBuffer based buffer.
This is fork of ElasticSearch's ByteBufferAllocator.Cleaner class
 
 
A special Executor which allows to chain a series of Executors and ChannelEventRunnableFilter.
A nexus to a network socket or a component which is capable of I/O operations such as read, write, connect, and bind.
A random and sequential accessible sequence of zero or more bytes (octets).
ByteInput implementation which reads its data from a ChannelBuffer
ByteOutput implementation which writes the data to a ChannelBuffer
A factory that creates or pools ChannelBuffers.
Locates an index of data in a ChannelBuffer.
An InputStream which reads data from a ChannelBuffer.
An OutputStream which writes data to a ChannelBuffer.
Creates a new ChannelBuffer by allocating new space or by wrapping or copying existing byte arrays, byte buffers and a string.
A set of configuration properties of a Channel.
A ChannelEventRunnable which sends the specified ChannelEvent downstream.
Handles or intercepts a downstream ChannelEvent, and sends a ChannelEvent to the next handler in a ChannelPipeline.
An I/O event or I/O request associated with a Channel.
 
 
A RuntimeException which is thrown when an I/O operation fails.
The main interface to a transport that creates a Channel associated with a certain communication entity such as a network socket.
The result of an asynchronous Channel I/O operation.
Listens to the result of a ChannelFuture.
ChannelFutureListener implementation which takes another ChannelFuture and notifies it once the operationComplete method was called.
Listens to the progress of a time-consuming I/O operation such as a large file transfer.
A thread-safe Set that contains open Channels and provides various bulk operations on them.
The result of an asynchronous ChannelGroup operation.
Listens to the result of a ChannelGroupFuture.
Handles or intercepts a ChannelEvent, and sends a ChannelEvent to the next handler in a ChannelPipeline.
Indicates that the same instance of the annotated ChannelHandler can be added to one or more ChannelPipelines multiple times without a race condition.
Enables a ChannelHandler to interact with its ChannelPipeline and other handlers.
A RuntimeException which is thrown when a LifeCycleAwareChannelHandler throws an Exception in its handler methods.
A global variable that is local to a Channel.
A list of ChannelHandlers which handles or intercepts ChannelEvents of a Channel.
A ChannelException which is thrown when a ChannelPipeline failed to process a ChannelEvent or when a ChannelPipelineFactory failed to initialize a ChannelPipeline.
Creates a new ChannelPipeline for a new Channel.
 
A helper class which provides various convenience methods related with Channel, ChannelHandler, and ChannelPipeline.
Receives and processes the terminal downstream ChannelEvents.
The current or future state of a Channel.
A ChannelEvent which represents the change of the Channel state.
This implementation of the AbstractTrafficShapingHandler is for channel traffic shaping, that is to say a per channel limitation of the bandwidth.
 
A ChannelEventRunnable which sends the specified ChannelEvent upstream.
Handles or intercepts an upstream ChannelEvent, and sends a ChannelEvent to the next handler in a ChannelPipeline.
A utility class that provides various common operations and constants related with Charset and its relevant classes.
A ChannelEvent which represents the notification of the state of a child Channel.
A ChunkedInput that fetches data from a file chunk by chunk.
A data stream of indefinite length which is consumed by ChunkedWriteHandler.
A ChunkedInput that fetches data from a file chunk by chunk using NIO FileChannel.
A ChunkedInput that fetches data from a ReadableByteChannel chunk by chunk.
A ChunkedInput that fetches data from an InputStream chunk by chunk.
A ChannelHandler that adds support for writing a large data stream asynchronously neither spending a lot of memory nor getting OutOfMemoryError.
 
 
 
 
please use ClassResolvers as instance factory
 
A helper class which creates a new client-side Channel and makes a connection attempt.
A RFC6265 compliant cookie decoder to be used client side.
 
A RFC6265 compliant cookie encoder to be used client side, so only name=value pairs are sent.
A ChannelFactory which creates a client-side SocketChannel.
Web Socket Frame for closing the connection
A helper that wraps an encoder or a decoder (codec) so that they can be used without doing actual I/O in unit tests or higher level codecs.
A RuntimeException which is thrown when a CodecEmbedder failed to encode or decode the specified input.
 
Logger factory which creates an Apache Commons Logging logger.
 
 
ReplayingDecoder which use an Unmarshaller to read the Object out of the ChannelBuffer.
OneToOneEncoder implementation which uses JBoss Marshalling to marshal an Object.
An encoder which serializes a Java object into a ChannelBuffer (interoperability version).
A skeletal ChannelFuture implementation which represents a ChannelFuture which has been completed already.
A virtual buffer which shows multiple buffers as a single merged buffer.
An IOException that is raised when compression or decompression failed.
An alternative identity-comparing ConcurrentMap which is similar to ConcurrentHashMap.
ConcurrentReferenceHashMap list entry.
Segments are specialized versions of hash tables.
 
An alternative weak-key identity-comparing ConcurrentMap which is similar to ConcurrentHashMap.
ConcurrentReferenceHashMap list entry.
Segments are specialized versions of hash tables.
 
A weak-key reference which stores the key hash needed for reclamation.
A helper class which creates a new server-side Channel for a connectionless transport.
ConnectException which will be thrown if a connection could not be established because of a connection timeout.
UnmarshallerProvider which store a reference to the Unmarshaller in the ChannelHandlerContext via the ChannelHandlerContext.setAttachment(Object) method.
Web Socket continuation frame containing continuation text or binary data.
Conversion utility class to parse a property represented as a string or an object.
Deprecated.
Use Cookie instead.
An interface defining an HTTP cookie.
Parent of Client and Server side cookie decoders
Deprecated.
Use io.netty.handler.codec.http.cookie.ClientCookieDecoder or io.netty.handler.codec.http.cookie.ServerCookieDecoder instead.
Parent of Client and Server side cookie encoders
Encodes Cookies into an HTTP header value.
 
 
Deprecated.
Duplicate of package private $io.netty.handler.codec.http.cookie.CookieUtil
An Exception which is thrown when the received frame data can not be decoded by a FrameDecoder implementation.
A UDP/IP Channel which is created by DatagramChannelFactory.
A ChannelFactory which creates a DatagramChannel.
 
Determines if Netty is running in a debug mode or not.
A helper that wraps a decoder so that it can be used without doing actual I/O in unit tests or higher level codecs.
The default SocketChannelConfig implementation.
The default ChannelFuture implementation.
The default ChannelGroup implementation.
The default ChannelGroupFuture implementation.
The default ChannelPipeline implementation.
 
The default ChildChannelStateEvent implementation.
The default Cookie implementation.
Deprecated.
Use io.netty.handler.codec.http.cookie.DefaultCookie instead.
The default DatagramChannelConfig implementation.
The default ExceptionEvent implementation.
 
The default HttpChunk implementation.
The default HttpChunkTrailer implementation.
 
Default factory giving Attribute and FileUpload according to constructor Attribute and FileUpload could be :
- MemoryAttribute, DiskAttribute or MixedAttribute
- MemoryFileUpload, DiskFileUpload or MixedFileUpload
according to the constructor.
 
The default HttpMessage implementation.
The default HttpRequest implementation.
The default HttpResponse implementation.
The default IdleStateEvent implementation.
 
The default LocalClientChannelFactory implementation.
 
The default LocalServerChannelFactory implementation.
Default implementation of MarshallerProvider which just create a new Marshaller on ever DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext) call.
The default NioSocketChannelConfig implementation.
The default NioSocketChannelConfig implementation.
The default ObjectSizeEstimator implementation for general purpose.
The default ServerSocketChannelConfig implementation.
The default ServerSocketChannelConfig implementation.
The default SocketChannelConfig implementation.
The default SpdyDataFrame implementation.
The default SpdyGoAwayFrame implementation.
 
 
The default SpdyHeadersFrame implementation.
The default SpdyPingFrame implementation.
The default SpdyRstStreamFrame implementation.
The default SpdySettingsFrame implementation.
 
The default SpdyStreamFrame implementation.
The default SpdySynReplyFrame implementation.
The default SpdySynStreamFrame implementation.
The default SpdyWindowUpdateFrame implementation.
Default implementation of UnmarshallerProvider which will just create a new Unmarshaller on every call to DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext)
The default WriteCompletionEvent implementation.
A decoder that splits the received ChannelBuffers by one or more delimiters.
A set of commonly used delimiters for DelimiterBasedFrameDecoder.
Utility that detects various properties specific to the current runtime environment, such as Java version and the availability of the sun.misc.Unsafe object.
A ChannelBufferFactory which pre-allocates a large chunk of direct buffer and returns its slice on demand.
Keeps sending random data to the specified address.
Handles a client-side channel.
Discards any incoming data.
Handles a server-side channel.
Disk implementation of Attributes
Disk FileUpload implementation that stores file into real files
The default downstream ChannelStateEvent implementation.
The default downstream MessageEvent implementation.
A derived buffer which simply forwards all data access requests to its parent.
A dynamic capacity buffer which increases its capacity as needed.
Sends one message when a connection is open and echoes back any received data to the server.
Handler implementation for the echo client.
Echoes back any received data from a client.
Handler implementation for the echo server.
TODO Make EmbeddedChannel implement ChannelConfig and ChannelSink to reduce overhead.
 
 
 
An immutable empty buffer implementation.
A helper that wraps an encoder so that it can be used without doing actual I/O in unit tests or higher level codecs.
Represents an object which contains another object that needs to be taken into account by ObjectSizeEstimator for more accurate object size estimation.
A ChannelEvent which represents the notification of an exception raised by a ChannelHandler or an I/O thread.
Forwards an upstream ChannelEvent to an Executor.
Shuts down a list of Executors.
A common interface for a class which depends on external resources that need explicit release or shutdown.
A utility class that provides the convenient shutdown of ExternalResourceReleasables.
Sends a sequence of integers to a FactorialServer to calculate the factorial of the specified integer.
Handler for a client-side channel.
Creates a newly configured ChannelPipeline for a client-side channel.
Receives a sequence of integers from a FactorialClient to calculate the factorial of the specified integer.
Handler for a server-side channel.
Creates a newly configured ChannelPipeline for a server-side channel.
The CompleteChannelFuture which is failed already.
This is a fair alternative of OrderedDownstreamThreadPoolExecutor .
This is a fair alternative of OrderedMemoryAwareThreadPoolExecutor .
A region of a file that is sent via a Channel which supports zero-copy file transfer.
FileUpload interface that could be in memory, on temporary file or any other implementations.
An TrustManagerFactory that trusts an X.509 certificate whose SHA1 checksum matches.
A decoder that splits the received ChannelBuffers by the fixed number of bytes.
The ReceiveBufferSizePredictor that always yields the same buffer size prediction.
The ReceiveBufferSizePredictorFactory that returns a FixedReceiveBufferSizePredictor with the pre-defined configuration.
Decodes the received ChannelBuffers into a meaningful frame object.
Class to implement monitoring at fix delay.
This implementation of the AbstractTrafficShapingHandler is for global and per channel traffic shaping, that is to say a global limitation of the bandwidth, whatever the number of opened channels and a per channel limitation of the bandwidth.

This version shall not be in the same pipeline than other TrafficShapingHandler.

The general use should be as follow:
Create your unique GlobalChannelTrafficShapingHandler like:

GlobalChannelTrafficShapingHandler myHandler = new GlobalChannelTrafficShapingHandler(executor);

The executor could be the underlying IO worker pool
pipeline.addLast(myHandler);

Note that this handler has a Pipeline Coverage of "all" which means only one such handler must be created and shared among all channels as the counter must be shared among all channels.

Other arguments can be passed like write or read limitation (in bytes/s where 0 means no limitation) or the check interval (in millisecond) that represents the delay between two computations of the bandwidth and so the call back of the doAccounting method (0 means no accounting at all).
Note that as this is a fusion of both Global and Channel Traffic Shaping, limits are in 2 sets, respectively Global and Channel.

A value of 0 means no accounting for checkInterval.
 
 
This implementation of the AbstractTrafficShapingHandler is for global traffic shaping, that is to say a global limitation of the bandwidth, whatever the number of opened channels.
 
 
A Timer optimized for approximated I/O timeout scheduling.
Bucket that stores HashedWheelTimeouts.
 
A skeletal implementation for Java heap buffers.
A ChannelBufferFactory which merely allocates a heap buffer with the specified capacity.
 
 
 
An HTTP chunk which is used for HTTP chunked transfer-encoding.
A ChannelHandler that aggregates an HttpMessage and its following HttpChunks into a single HttpMessage with no following HttpChunks.
The last HttpChunk which has trailing headers.
A combination of HttpRequestEncoder and HttpResponseDecoder which enables easier client side HTTP implementation.
 
 
Compresses an HttpMessage and an HttpChunk in gzip or deflate encoding while respecting the "Accept-Encoding" header.
Decodes the content of the received HttpRequest and HttpChunk.
Decompresses an HttpMessage and an HttpChunk compressed in gzip or deflate encoding.
Encodes the content of the outbound HttpResponse and HttpChunk.
Extended interface for InterfaceHttpData
Interface to enable creation of InterfaceHttpData objects
This DateFormat decodes 3 formats of Date, but only encodes the one, the first: Sun, 06 Nov 1994 08:49:37 GMT: standard specification, the only one with valid generation Sun, 06 Nov 1994 08:49:37 GMT: obsolete specification Sun Nov 6 08:49:37 1994: obsolete specification
First obsolete format
Second obsolete format
Provides the constants for the standard HTTP header names and values and commonly used utility methods that accesses an HttpMessage.
Standard HTTP header names.
Standard HTTP header values.
An HTTP server that sends back the content of the received HTTP request in a pretty plaintext form.
 
 
An HTTP message which provides common properties for HttpRequest and HttpResponse.
Decodes ChannelBuffers into HttpMessages and HttpChunks.
The internal state of HttpMessageDecoder.
Encodes an HttpMessage or an HttpChunk into a ChannelBuffer.
The request method of HTTP or its derived protocols, such as RTSP and ICAP.
Shared Static object between HttpMessageDecoder, HttpPostRequestDecoder and HttpPostRequestEncoder
Exception when NO Backend Array is found
This class intends to decrease the CPU in seeking ahead some bytes in HttpPostRequestDecoder
Allowed mechanism for multipart mechanism := "7bit" / "8bit" / "binary" Not allowed: "quoted-printable" / "base64"
This decoder will decode Body and can handle POST BODY in multipart form.
This decoder will decode Body and can handle POST BODY (both multipart and standard).
Exception when the body is fully decoded, even if there is still data
Exception when an error occurs while decoding
states follow NOTSTARTED PREAMBLE ( (HEADERDELIMITER DISPOSITION (FIELD | FILEUPLOAD))* (HEADERDELIMITER DISPOSITION MIXEDPREAMBLE (MIXEDDELIMITER MIXEDDISPOSITION MIXEDFILEUPLOAD)+ MIXEDCLOSEDELIMITER)* CLOSEDELIMITER)+ EPILOGUE First status is: NOSTARTED Content-type: multipart/form-data, boundary=AaB03x => PREAMBLE in Header --AaB03x => HEADERDELIMITER content-disposition: form-data; name="field1" => DISPOSITION Joe Blow => FIELD --AaB03x => HEADERDELIMITER content-disposition: form-data; name="pics" => DISPOSITION Content-type: multipart/mixed, boundary=BbC04y --BbC04y => MIXEDDELIMITER Content-disposition: attachment; filename="file1.txt" => MIXEDDISPOSITION Content-Type: text/plain ...
Exception when try reading data from request in chunked format, and not enough data are available (need more chunks)
This encoder will help to encode Request for a FORM as POST.
Different modes to use to encode form data.
Exception when an error occurs while encoding
This decoder will decode Body and can handle standard (non multipart) POST BODY.
An HTTP request.
Decodes ChannelBuffers into HttpRequests and HttpChunks.
Encodes an HttpRequest or an HttpChunk into a ChannelBuffer.
An HTTP response.
Decodes ChannelBuffers into HttpResponses and HttpChunks.
Encodes an HttpResponse or an HttpChunk into a ChannelBuffer.
The response code and its description of HTTP or its derived protocols, such as RTSP and ICAP.
A combination of HttpRequestDecoder and HttpResponseEncoder which enables easier server side HTTP implementation.
A simple HTTP client that prints out the content of the HTTP response to System.out to test HttpSnoopServer.
 
 
An HTTP server that sends back the content of the received HTTP request in a pretty plaintext form.
 
 
 
A simple handler that serves incoming HTTP requests to send their respective HTTP responses.
 
An HTTP tunneled version of the telnet client example.
 
Creates a client-side SocketChannel which connects to an HttpTunnelingServlet to communicate with the server application behind the HttpTunnelingServlet.
 
An HttpServlet that proxies an incoming data to the actual server and vice versa.
 
The ChannelConfig of a client-side HTTP tunneling SocketChannel.
 
 
 
 
 
 
The version of HTTP or its derived protocols, such as RTSP and ICAP.
An Enum that represents the idle state of a Channel.
An extended SimpleChannelHandler that adds the handler method for an IdleStateEvent.
An extended SimpleChannelUpstreamHandler that adds the handler method for an IdleStateEvent.
A ChannelEvent that is triggered when a Channel has been idle for a while.
Triggers an IdleStateEvent when a Channel has not performed read, write, or both operation for a while.
 
Executor which executes the command in the caller thread.
An insecure TrustManagerFactory that trusts all X.509 certificates without any verification.
Interface for all Objects that could be encoded/decoded using HttpPostRequestEncoder/Decoder
 
 
This Attribute is only for Encoder use to insert special command between object if needed (like Multipart Mixed mode)
Internal-use-only logger used by Netty.
Creates an InternalLogger or changes the default factory implementation.
The log level that InternalLogger can log at.
Internet Protocol (IP) families
The Interface IpFilteringHandler.
General class that handle Ip Filtering.
The listener interface for receiving ipFilter events.
This Interface defines an Ip Filter Rule.
Implementation of Filter of IP based on ALLOW and DENY rules.


This implementation could be changed by implementing a new IpFilterRule than default IpV4SubnetFilterRule (IPV4 support only), IpSubnetFilterRule (IPV4 and IPV6 support) or IpFilterRule (IP and host name string pattern support) .

The check is done by going from step to step in the underlying array of IpFilterRule.
Each IpFilterRule answers to the method accept if the InetAddress is accepted or not, according to its implementation.
The Class IpFilterRuleList is a helper class to generate a List of Rules from a string.
This Interface defines an IpSet object.
This class allows to check if an IP V4 or V6 Address is contained in a subnet.
Ip V4 and Ip V6 filter rule.

Note that mix of IPV4 and IPV6 is allowed but it is not recommended.
This class allows to check if an IP-V4-Address is contained in a subnet.
Supported Formats for the Subnets are: 1.1.1.1/255.255.255.255 or 1.1.1.1/32 (CIDR-Notation) and (InetAddress,Mask) where Mask is a integer for CIDR-notation or a String for Standard Mask notation.


Example1:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/24");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));

Example1 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, 24);
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123


Example2:
IpV4Subnet ips = new IpV4Subnet("192.168.1.0/255.255.255.0");
System.out.println("Result: "+ ips.contains("192.168.1.123"));
System.out.println("Result: "+ ips.contains(inetAddress2));

Example2 bis:
IpV4Subnet ips = new IpV4Subnet(inetAddress, "255.255.255.0");
where inetAddress is 192.168.1.0 and inetAddress2 is 192.168.1.123
IpV4 only Filter Rule
Logger factory which creates a JBoss Logging logger.
Logger factory which creates a java.util.logging logger.
A client-side SslContext which uses JDK's SSL/TLS implementation.
An SslContext which uses JDK's SSL/TLS implementation.
A server-side SslContext which uses JDK's SSL/TLS implementation.
Compresses a ChannelBuffer using the deflate algorithm.
 
A decoder that splits the received ChannelBuffers dynamically by the value of the length field in the message.
An encoder that prepends the length of the message.
A ChannelHandler that is notified when it is added to or removed from a ChannelPipeline.
ByteInput implementation which wraps another ByteInput and throws a LimitingByteInput.TooBigObjectException if the read limit was reached.
Exception that will get thrown if the Object is to big to unmarshall
A decoder that splits the received ChannelBuffers on line endings.
A little-endian Java heap buffer.
An endpoint in the local transport.
A Channel for the local transport.
 
A ChannelFactory that creates a client-side LocalChannel.
 
Deploy this in JBossAS 5 or other IoC container by adding the following bean.
 
A ServerChannel for the local transport.
 
Sends a list of continent/city pairs to a LocalTimeServer to get the local times of the specified cities.
 
 
 
Protobuf enum org.jboss.netty.example.localtime.Continent
Protobuf enum org.jboss.netty.example.localtime.DayOfWeek
Protobuf type org.jboss.netty.example.localtime.LocalTime
Protobuf type org.jboss.netty.example.localtime.LocalTime
 
Protobuf type org.jboss.netty.example.localtime.LocalTimes
Protobuf type org.jboss.netty.example.localtime.LocalTimes
 
Protobuf type org.jboss.netty.example.localtime.Location
Protobuf type org.jboss.netty.example.localtime.Location
 
Protobuf type org.jboss.netty.example.localtime.Locations
Protobuf type org.jboss.netty.example.localtime.Locations
 
Receives a list of continent/city pairs from a LocalTimeClient to get the local times of the specified cities.
 
 
Apache Log4J logger.
Logger factory which creates an Apache Log4J logger.
A ChannelHandler that logs all events via InternalLogger.
A Map-backed Set.
This provider is responsible to get a Marshaller for the given ChannelHandlerContext.
Decoder which MUST be used with MarshallingEncoder.
OneToOneEncoder implementation which uses JBoss Marshalling to marshal an Object.
Memory implementation of Attributes
A ThreadPoolExecutor which blocks the task submission when there's too many tasks in the queue.
 
 
 
 
Default FileUpload implementation that stores file into memory.

Warning: be aware of the memory limitation.
A ChannelEvent which represents the transmission or reception of a message.
Mixed implementation using both in Memory and in File with a limit of size
Mixed implementation using both in Memory and in File with a limit of size
Helper class to load JNI resources.
An OSGi BundleActivator that configures logging.
A bean that configures the default InternalLoggerFactory.
A bean that configures the default InternalLoggerFactory.
A class that holds a number of network-related constants.
 
Special ChannelConfig sub-type which offers extra methods which are useful for NIO.
Boss implementation that handles the connection attempts of clients
Holds NioClientBoss instances to use
 
A ClientSocketChannelFactory which creates a client-side NIO-based SocketChannel.
 
Provides an NIO based DatagramChannel.
A DatagramChannelFactory that creates a NIO-based connectionless DatagramChannel.
Receives downstream events from a ChannelPipeline.
A class responsible for registering channels with Selector.
Default implementation which hands of NioDatagramWorker's
 
 
Boss implementation which handles accepting of new connections
Holds NioServerBoss instances to use
 
A ServerSocketChannelFactory which creates a server-side NIO-based ServerSocketChannel.
 
 
 
Default implementation which hands of NioWorker's
 
Special SSLException which will get thrown if a packet is received that not looks like a TLS/SSL record.
Encodes a Number into the binary representation prepended with a magic number ('F' or 0x46) and a 32-bit length prefix.
A decoder which deserializes the received ChannelBuffers into Java objects.
An ObjectInput which is interoperable with ObjectEncoder and ObjectEncoderOutputStream.
Modification of EchoClient which utilizes Java object serialization.
Handler implementation for the object echo client.
Modification of EchoServer which utilizes Java object serialization.
Handles both client-side and server-side handler depending on which constructor was called.
An encoder which serializes a Java object into a ChannelBuffer.
An ObjectOutput which is interoperable with ObjectDecoder and ObjectDecoderInputStream.
Estimates the size of an object in bytes.
 
 
A ClientSocketChannelFactory which creates a client-side blocking I/O based SocketChannel.
 
 
A DatagramChannelFactory which creates a blocking I/O based DatagramChannel.
 
 
 
A ServerSocketChannelFactory which creates a server-side blocking I/O based ServerSocketChannel.
 
 
 
Handler that block any new connection if there are already a currently active channel connected with the same InetAddress (IP).

Transforms a received message into another message.
Transforms a write request into another write request.
Special OneToOneEncoder which enforce strict ordering of encoding and writing.
Generates a self-signed certificate using sun.security.x509 package provided by OpenJDK.
Tells if netty-tcnative and its OpenSSL support are available.
A server-side SslContext which uses OpenSSL's SSL/TLS implementation.
Stats exposed by an OpenSSL session context.
Executor which should be used for downstream ChannelEvent's.
A MemoryAwareThreadPoolExecutor which makes sure the events from the same Channel are executed sequentially.
OSGi LogService logger.
Logger factory which creates an OSGi LogService logger.
The Class PatternRule represents an IP filter rule using string patterns.
Reads a PEM file and converts it into a list of DERs so that they are imported into a KeyStore easily.
Web Socket frame containing binary data
Web Socket frame containing binary data
Serves two protocols (HTTP and Factorial) using only one port, enabling either SSL or GZIP dynamically on demand.
Manipulates the current pipeline dynamically to switch protocols or enable SSL or GZIP.
Exception which should get thrown if a Channel got closed before it is expected
Decodes a received ChannelBuffer into a Google Protocol Buffers Message and MessageLite.
Encodes the requested Google Protocol Buffers Message and MessageLite into a ChannelBuffer.
A decoder that splits the received ChannelBuffers dynamically by the value of the Google Protocol Buffers Base 128 Varints integer length field in the message.
An encoder that prepends the the Google Protocol Buffers Base 128 Varints integer length field.
Helper class which convert the InternetProtocolFamily.
Splits an HTTP query string into a path string and key-value parameter pairs.
Creates an URL-encoded URI from a path string and key-value parameter pairs.
 
A UDP broadcast client that asks for a quote of the moment (QOTM) to QuoteOfTheMomentServer.
 
A UDP server that responds to the QOTM (quote of the moment) request to a QuoteOfTheMomentClient.
 
A derived buffer which forbids any write requests to its parent.
A TimeoutException raised by ReadTimeoutHandler when no data was read within a certain period of time.
Raises a ReadTimeoutException when no data was read within a certain period of time.
 
Predicts the number of readable bytes in the receive buffer of a Channel.
 
 
A specialized variation of FrameDecoder which enables implementation of a non-blocking decoder in the blocking I/O paradigm.
 
 
Standard RTSP header names and values.
Standard RTSP header names.
Standard RTSP header values.
Decodes ChannelBuffers into RTSP messages represented in HttpMessages.
Encodes an RTSP message represented in HttpMessage into a ChannelBuffer.
The request method of RTSP.
Decodes ChannelBuffers into RTSP requests represented in HttpRequests.
Encodes an RTSP request represented in HttpRequest into a ChannelBuffer.
Decodes ChannelBuffers into RTSP responses represented in HttpResponses.
Encodes an RTSP response represented in HttpResponse into a ChannelBuffer.
The status code and its description of a RTSP response.
The version of RTSP.
Simple SSL chat client modified from TelnetClient.
Handles a client-side channel.
Creates a newly configured ChannelPipeline for a new channel.
Simple SSL chat server modified from TelnetServer.
Handles a server-side channel.
 
Creates a newly configured ChannelPipeline for a new channel.
 
Generates a temporary self-signed certificate for testing purposes.
A helper class which creates a new server-side Channel and accepts incoming connections.
A Channel that accepts an incoming connection attempt and creates its child Channels by accepting them.
A ChannelFactory that creates a ServerChannel.
A RFC6265 compliant cookie decoder to be used server side.
A RFC6265 compliant cookie encoder to be used server side, so some fields are sent (Version is typically ignored).
A TCP/IP ServerChannel which accepts incoming TCP/IP connections.
This implementation of a WorkerPool should be used if you plan to share a WorkerPool between different Factories.
Warn when user creates too many instances to avoid OutOfMemoryError.
A ChannelDownstreamHandler which provides an individual handler method for each event type.
A ChannelHandler which provides an individual handler method for each event type.
A ChannelUpstreamHandler which provides an individual handler method for each event type.
Helps to implement a custom TrustManagerFactory.
 
SLF4J logger.
Logger factory which creates a SLF4J logger.
A derived buffer which exposes its parent's sub-region only.
A TCP/IP socket Channel which was either accepted by ServerSocketChannel or created by ClientSocketChannelFactory.
 
 
 
 
 
 
 
An socks auth request.
 
An socks auth response.
 
An socks cmd request.
 
An socks cmd response.
 
 
An socks init request.
 
An socks init response.
 
An abstract class that defines a SocksMessage, providing common properties for SocksRequest and SocksResponse.
 
 
 
 
 
 
 
 
Encodes an SocksMessage into a ChannelBuffer.
An abstract class that defines a SocksRequest, providing common properties for SocksInitRequest, SocksAuthRequest, SocksCmdRequest and UnknownSocksRequest.
Type of socks request
An abstract class that defines a SocksResponse, providing common properties for SocksInitResponse, SocksAuthResponse, SocksCmdResponse and UnknownSocksResponse.
Type of socks response
 
 
A SPDY Protocol DATA Frame
A SPDY Protocol Frame
A ChannelHandler that encodes and decodes SPDY Frames.
Decodes ChannelBuffers into SPDY Frames.
 
Callback interface for SpdyFrameDecoder.
Encodes a SPDY Frame into a ChannelBuffer.
A SPDY Protocol GOAWAY Frame
 
 
 
 
 
 
 
 
Provides the constants for the standard SPDY HTTP header names and commonly used utility methods that access a SpdyHeadersFrame.
SPDY HTTP header names
A SPDY Protocol HEADERS Frame
A combination of SpdyHttpDecoder and SpdyHttpEncoder
 
Provides the constants for the header names and the utility methods used by the SpdyHttpDecoder and SpdyHttpEncoder.
SPDY HTTP header names
SimpleChannelHandler that takes care of adding the right streamId to the HttpResponse if one is not present.
ChannelUpstreamHandler which is responsible to setup the ChannelPipeline either for HTTP or SPDY.
 
A SPDY Protocol PING Frame
 
A SPDY Protocol RST_STREAM Frame
 
 
Manages streams within a SPDY session.
 
The SPDY session status code and its description.
A SPDY Protocol SETTINGS Frame
A SPDY Protocol Frame that is associated with an individual SPDY Stream
The SPDY stream status code and its description.
A SPDY Protocol SYN_REPLY Frame
A SPDY Protocol SYN_STREAM Frame
 
A SPDY Protocol WINDOW_UPDATE Frame
A ByteBuffer pool dedicated for SslHandler performance improvement.
A secure socket protocol implementation which acts as a factory for SSLEngine and SslHandler.
Adds SSL · TLS and StartTLS support to a Channel.
 
 
An enumeration of SSL/TLS protocol providers.
Decodes a received ChannelBuffer into a String.
Encodes the requested String into a ChannelBuffer.
String utility class.
The CompleteChannelFuture which is succeeded already.
FilterInputStream which allows a user to change the underlying stream at any time.
A collection of utility methods to retrieve and parse the values of the Java system properties.
Simplistic telnet client.
Handles a client-side channel.
Creates a newly configured ChannelPipeline for a new channel.
Simplistic telnet server.
Handles a server-side channel.
Creates a newly configured ChannelPipeline for a new channel.
Web Socket text frame with assumed UTF-8 encoding
 
Insecure SecureRandom which relies on ThreadLocalRandom for random number generation.
UnmarshallerProvider implementation which use a ThreadLocal to store references to Marshaller instances.
A random number generator isolated to the current thread.
UnmarshallerProvider implementation which use a ThreadLocal to store references to Unmarshaller instances.
Overrides the thread name proposed by ThreadRenamingRunnable.
A Runnable that changes the current thread name and reverts it back when its execution ends.
A handle associated with a TimerTask that is returned by a Timer.
A TimeoutException when no data was either read or written within a certain period of time.
Schedules TimerTasks for one-time future execution in a background thread.
A task which is executed after the delay specified with Timer.newTimeout(TimerTask, long, TimeUnit).
An Exception which is thrown when the length of the frame decoded is greater than the maximum.
TrafficCounter is associated with AbstractTrafficShapingHandler.
Class to implement monitoring at fix delay
A derived buffer which hides its parent's tail data beyond a certain index.
An unknown socks message.
An unknown socks request.
An unknown socks response.
This provider is responsible to get an Unmarshaller for a ChannelHandlerContext
An Exception which is thrown when a user calls an unsupported operation on a ChannelBuffer in a ReplayingDecoder implementation.
Disables shutdown of an Executor by wrapping the Executor.
The default upstream ChannelStateEvent implementation.
The default upstream MessageEvent implementation.
Connects to a server periodically to measure and print the uptime of the server.
Keep reconnecting to the server while printing out the current uptime and connection attempt status.
Checks UTF8 bytes for validity before converting it into a string
Provides the version information of Netty.
A delegating ExecutorService with its own termination management.
A placeholder Enum which could be specified as a type parameter of ReplayingDecoder when a user wants to manage the decoder state or there's no state to manage.
 
Encodes a WebSocketFrame into a ChannelBuffer.
Decodes a web socket frame from wire protocol version 7 format.
Encodes a web socket frame into wire protocol version 7 format.
Decodes a web socket frame from wire protocol version 8 format.
 
Encodes a web socket frame into wire protocol version 8 format.
Decodes a web socket frame from wire protocol version 13 format.
Encodes a web socket frame into wire protocol version 13 format.
 
 
Base class for web socket client handshake implementations
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 00
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 07
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 10
Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 17
Instances the appropriate handshake class to use for clients
Base class for web socket frames
Handler that aggregate fragmented WebSocketFrame's.
Type of web socket frames
Exception during handshaking process
A HTTP server which serves Web Socket requests at: http://localhost:8080/websocket Open your browser at http://localhost:8080/, then the demo page will be loaded and a Web Socket connection will be made automatically.
Handles handshakes and messages
Base class for server side web socket opening and closing handshakes
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 00
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 07
Performs server side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 10
Performs server side opening and closing handshakes for RFC 6455 (originally web socket specification version draft-ietf-hybi-thewebsocketprotocol- 17).
Instances the appropriate handshake class to use for servers
Generates the demo HTML page which is served at http://localhost:8080/
 
Handles WebSocket control frames (Close, Ping, Pong) and data frames (Text and Binary) are passed to the next handler in the pipeline.
Handles the HTTP handshake (the HTTP Upgrade request)
TODO Document me.
Versions of the web socket specification.
A Worker is responsible to dispatch IO operations
The WorkerPool is responsible to hand of Worker's on demand
The common interface for buffer wrappers and derived buffers.
A ChannelEvent which represents the notification of the completion of a write request on a Channel.
A TimeoutException raised by WriteTimeoutHandler when no data was written within a certain period of time.
Raises a WriteTimeoutException when no data was written within a certain period of time.
 
Decompresses a ChannelBuffer using the deflate algorithm.
Compresses a ChannelBuffer using the deflate algorithm.
Utility methods used by ZlibEncoder and ZlibDecoder.
The container file formats that wrap the stream compressed by the DEFLATE algorithm.