@ChannelHandler.Sharable public final class MqttEncoder extends MessageToMessageEncoder<MqttMessage>
ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
static MqttEncoder |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
protected void |
encode(ChannelHandlerContext ctx,
MqttMessage msg,
List<Object> out)
Encode from one message to an other.
|
acceptOutboundMessage, write
bind, close, connect, deregister, disconnect, flush, read
exceptionCaught, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
public static final MqttEncoder INSTANCE
protected void encode(ChannelHandlerContext ctx, MqttMessage msg, List<Object> out) throws Exception
MessageToMessageEncoder
encode
in class MessageToMessageEncoder<MqttMessage>
ctx
- the ChannelHandlerContext
which this MessageToMessageEncoder
belongs tomsg
- the message to encode to an other oneout
- the List
into which the encoded msg should be added
needs to do some kind of aggragationException
- is thrown if an error accourCopyright © 2008–2016 The Netty Project. All rights reserved.