public class SimpleProtocolDecoderOutput extends java.lang.Object implements ProtocolDecoderOutput
ProtocolDecoderOutput based on queue.| Constructor and Description |
|---|
SimpleProtocolDecoderOutput(IoSession session,
IoFilter.NextFilter nextFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
flush()
Flushes all messages you wrote via
ProtocolDecoderOutput.write(Object) to
the next filter. |
void |
write(java.lang.Object message)
Callback for
ProtocolDecoder to generate decoded messages. |
public SimpleProtocolDecoderOutput(IoSession session, IoFilter.NextFilter nextFilter)
public void write(java.lang.Object message)
ProtocolDecoderOutputProtocolDecoder to generate decoded messages.
ProtocolDecoder must call ProtocolDecoderOutput.write(Object) for each
decoded messages.write in interface ProtocolDecoderOutputmessage - the decoded messagepublic void flush()
ProtocolDecoderOutputProtocolDecoderOutput.write(Object) to
the next filter.flush in interface ProtocolDecoderOutput