@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) |
writebind, close, connect, deregister, disconnect, flush, readensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitexceptionCaught, handlerAdded, handlerRemovedprivate 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
MessageToMessageEncodertrue 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.Exceptionprotected void encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) throws java.lang.Exception
MessageToMessageEncoderencode 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)