All Implemented Interfaces:

ChannelHandler, ChannelOutboundHandler

Direct Known Subclasses:

Base64Encoder, ByteArrayEncoder, HttpObjectEncoder, ProtobufEncoder, SctpOutboundByteStreamHandler, SpdyHttpEncoder, StringEncoder, WebSocket00FrameEncoder, WebSocket08FrameEncoder

public abstract class MessageToMessageEncoder<I>
extends ChannelOutboundHandlerAdapter 

 public class IntegerToStringEncoder extends
 MessageToMessageEncoder<Integer> {
  @Override
 public void encode(ChannelHandlerContext ctx, Integer message, List<Object> out)
 throws Exception {
 out.add(message.toString());
 }
 }
 

• Nested Class Summary

  • Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

    ChannelHandler.Sharable

• Constructor Summary

  Constructors

  Modifier	Constructor and Description
  protected	MessageToMessageEncoder () Create a new instance which will try to detect the types to match out of the type parameter of the class.
  protected	MessageToMessageEncoder (java.lang.Class<? extends I> outboundMessageType) Create a new instance

• Method Summary

  All Methods

  Modifier and Type	Method and Description
  boolean	acceptOutboundMessage (java.lang.Object msg) Returns true if the given message should be handled.
  protected abstract void	encode (ChannelHandlerContext ctx, I msg, java.util.List<java.lang.Object> out) Encode from one message to an other.
  void	write (ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) Calls ChannelHandlerContext.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.

  • Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

    bind, close, connect, deregister, disconnect, flush, read

  • Methods inherited from class io.netty.channel.ChannelHandlerAdapter

    ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable

  • Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Methods inherited from interface io.netty.channel.ChannelHandler

    exceptionCaught, handlerAdded, handlerRemoved

• Constructor Detail

  • MessageToMessageEncoder

    protected MessageToMessageEncoder()

    Create a new instance which will try to detect the types to match out of the type parameter of the class.

  • MessageToMessageEncoder

    protected MessageToMessageEncoder(java.lang.Class<? extends I> outboundMessageType)

    Create a new instance

    Parameters:

    outboundMessageType - The type of messages to match and so encode

• Method Detail

  • acceptOutboundMessage

    public boolean acceptOutboundMessage(java.lang.Object msg)
     throws java.lang.Exception

    Returns true if the given message should be handled. If false it will be passed to the next ChannelOutboundHandler in the ChannelPipeline.

    Throws:

    java.lang.Exception

  • write

    public void write(ChannelHandlerContext ctx,
     java.lang.Object msg,
     ChannelPromise promise)
     throws java.lang.Exception

    Description copied from class: ChannelOutboundHandlerAdapter
    Calls ChannelHandlerContext.write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

    Specified by:

    write in interface ChannelOutboundHandler

    Overrides:

    write in class ChannelOutboundHandlerAdapter

    Parameters:

    ctx - the ChannelHandlerContext for which the write operation is made

    msg - the message to write

    promise - the ChannelPromise to notify once the operation completes

    Throws:

    java.lang.Exception - thrown if an error occurs

  • encode

    protected abstract void encode(ChannelHandlerContext ctx,
     I msg,
     java.util.List<java.lang.Object> out)
     throws java.lang.Exception

    Encode from one message to an other. This method will be called for each written message that can be handled by this encoder.

    Parameters:

    ctx - the ChannelHandlerContext which this MessageToMessageEncoder belongs to

    msg - the message to encode to an other one

    out - the List into which the encoded msg should be added needs to do some kind of aggregation

    Throws:

    java.lang.Exception - is thrown if an error occurs