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.The
ReceiveBufferSizePredictorFactory that creates a new
AdaptiveReceiveBufferSizePredictor.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.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
A Pool that holds
Boss instancesGenerates 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 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 ChannelBufferByteOutput implementation which writes the data to a ChannelBufferA 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.ChannelEventRunnableFilter implementation which matches ChannelDownstreamEventRunnableHandles 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.
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
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.ChannelEventRunnableFilter which matches ChannelDownstreamEventRunnableHandles 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 factoryA 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.Apache Commons Logging
logger.
Logger factory which creates an
Apache Commons Logging
logger.
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.
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.CookieUtilAn
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
ChannelConfig for a DatagramChannel.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.
- 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.Version for
GlobalChannelTrafficShapingHandler.Class to implement monitoring at fix delay.
This implementation of the
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.
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.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.The internal state of
HttpMessageDecoder.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.
An HTTP response.
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.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
The check is done by going from step to step in the underlying array of IpFilterRule.
Each
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.
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
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
JBoss Logging
logger.
Logger factory which creates a
JBoss Logging
logger.
java.util.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 unmarshallA 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.A
ServerChannelFactory that creates a LocalServerChannel.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.ContinentProtobuf enum
org.jboss.netty.example.localtime.DayOfWeekProtobuf type
org.jboss.netty.example.localtime.LocalTimeProtobuf type
org.jboss.netty.example.localtime.LocalTimeProtobuf type
org.jboss.netty.example.localtime.LocalTimesProtobuf type
org.jboss.netty.example.localtime.LocalTimesProtobuf type
org.jboss.netty.example.localtime.LocationProtobuf type
org.jboss.netty.example.localtime.LocationProtobuf type
org.jboss.netty.example.localtime.LocationsProtobuf type
org.jboss.netty.example.localtime.LocationsReceives 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.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.
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 clientsHolds
NioClientBoss instances to useA
ClientSocketChannelFactory which creates a client-side NIO-based
SocketChannel.Provides an NIO based
DatagramChannel.A
DatagramChannelConfig for a NIO TCP/IP 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'sBoss implementation which handles accepting of new connections
Holds
NioServerBoss instances to useA
ServerSocketChannelFactory which creates a server-side NIO-based
ServerSocketChannel.A
SocketChannelConfig for a NIO TCP/IP SocketChannel.Default implementation which hands of
NioWorker'sSpecial
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.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.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.Implements a
SSLEngine using
OpenSSL BIO abstractions.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
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.Creates a new
ReceiveBufferSizePredictor.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
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.A
ChannelConfig for a ServerSocketChannel.A
ChannelFactory which creates a ServerSocketChannel.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.A
ChannelConfig for a SocketChannel.An socks auth request.
Decodes
ChannelBuffers into SocksAuthRequest.An socks auth response.
Decodes
ChannelBuffers into SocksAuthResponse.An socks cmd request.
Decodes
ChannelBuffers into SocksCmdRequest.An socks cmd response.
Decodes
ChannelBuffers into SocksCmdResponse.An socks init request.
Decodes
ChannelBuffers into SocksInitRequest.An socks init response.
Decodes
ChannelBuffers into SocksInitResponse.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 SpdyHttpEncoderDecodes
SpdySynStreamFrames, SpdySynReplyFrames,
and SpdyDataFrames into HttpRequests and HttpResponses.Encodes
HttpRequests, HttpResponses, and HttpChunks
into SpdySynStreamFrames and SpdySynReplyFrames.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.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
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 ChannelHandlerContextAn
Exception which is thrown when a user calls an unsupported
operation on a ChannelBuffer in a ReplayingDecoder
implementation.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.Decodes
ChannelBuffers into WebSocketFrames.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 operationsThe
WorkerPool is responsible to hand of Worker's on demandThe 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.
Cookieinstead.