@UnstableApi public final class SmtpRequestEncoder extends MessageToMessageEncoder<java.lang.Object>
ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
private boolean |
contentExpected |
private static byte[] |
CRLF |
private static byte[] |
DOT_CRLF |
private static ByteBuf |
DOT_CRLF_BUFFER |
private static byte |
SP |
Constructor and Description |
---|
SmtpRequestEncoder() |
Modifier and Type | Method and Description |
---|---|
boolean |
acceptOutboundMessage(java.lang.Object msg)
Returns
true if the given message should be handled. |
protected void |
encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
private static void |
writeParameters(java.util.List<java.lang.CharSequence> parameters,
ByteBuf out) |
write
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
private static final byte[] CRLF
private static final byte[] DOT_CRLF
private static final byte SP
private static final ByteBuf DOT_CRLF_BUFFER
private boolean contentExpected
public boolean acceptOutboundMessage(java.lang.Object msg) throws java.lang.Exception
MessageToMessageEncoder
true
if the given message should be handled. If false
it will be passed to the next
ChannelOutboundHandler
in the ChannelPipeline
.acceptOutboundMessage
in class MessageToMessageEncoder<java.lang.Object>
java.lang.Exception
protected void encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageEncoder
encode
in class MessageToMessageEncoder<java.lang.Object>
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 aggregationjava.lang.Exception
- is thrown if an error occursprivate static void writeParameters(java.util.List<java.lang.CharSequence> parameters, ByteBuf out)