Class ProtocolCodecSession

java.lang.Object

org.apache.mina.core.session.AbstractIoSession

org.apache.mina.core.session.DummySession

org.apache.mina.filter.codec.ProtocolCodecSession

All Implemented Interfaces:

IoSession

public class ProtocolCodecSession
extends DummySession

A virtual IoSession that provides ProtocolEncoderOutput and ProtocolDecoderOutput. It is useful for unit-testing codec and reusing codec for non-network-use (e.g. serialization).

Encoding

ProtocolCodecSession session = new ProtocolCodecSession();
ProtocolEncoder encoder = ...;
MessageX in = ...;

encoder.encode(session, in, session.getProtocolEncoderOutput());

IoBuffer buffer = session.getProtocolDecoderOutputQueue().poll();

Decoding

ProtocolCodecSession session = new ProtocolCodecSession();
ProtocolDecoder decoder = ...;
IoBuffer in = ...;

decoder.decode(session, in, session.getProtocolDecoderOutput());

Object message = session.getProtocolDecoderOutputQueue().poll();

Field Summary

Fields

Modifier and Type	Field	Description
private final AbstractProtocolDecoderOutput	decoderOutput
private final AbstractProtocolEncoderOutput	encoderOutput
private final WriteFuture	notWrittenFuture

Fields inherited from class AbstractIoSession

CLOSE_REQUEST, MESSAGE_SENT_REQUEST

Constructor Summary

Constructors

Constructor	Description
ProtocolCodecSession()	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
ProtocolDecoderOutput	getDecoderOutput()
Queue<Object>	getDecoderOutputQueue()
ProtocolEncoderOutput	getEncoderOutput()
Queue<Object>	getEncoderOutputQueue()

Methods inherited from class DummySession

getConfig, getFilterChain, getHandler, getLocalAddress, getProcessor, getRemoteAddress, getService, getTransportMetadata, setConfig, setHandler, setLocalAddress, setRemoteAddress, setScheduledWriteBytes, setScheduledWriteMessages, setService, setTransportMetadata, updateThroughput

Methods inherited from class AbstractIoSession

close, close, closeNow, closeOnFlush, containsAttribute, decreaseReadBufferSize, decreaseScheduledBytesAndMessages, destroy, equals, getAttachment, getAttribute, getAttribute, getAttributeKeys, getAttributeMap, getBothIdleCount, getCloseFuture, getCreationTime, getCurrentWriteMessage, getCurrentWriteRequest, getId, getIdleCount, getLastBothIdleTime, getLastIdleTime, getLastIoTime, getLastReaderIdleTime, getLastReadTime, getLastWriterIdleTime, getLastWriteTime, getReadBytes, getReadBytesThroughput, getReaderIdleCount, getReadMessages, getReadMessagesThroughput, getScheduledWriteBytes, getScheduledWriteMessages, getServiceAddress, getWriteRequestQueue, getWriterIdleCount, getWrittenBytes, getWrittenBytesThroughput, getWrittenMessages, getWrittenMessagesThroughput, hashCode, increaseIdleCount, increaseReadBufferSize, increaseReadBytes, increaseReadMessages, increaseScheduledWriteBytes, increaseScheduledWriteMessages, increaseWrittenBytes, increaseWrittenMessages, isActive, isBothIdle, isClosing, isConnected, isIdle, isReaderIdle, isReadSuspended, isScheduledForFlush, isSecured, isWriterIdle, isWriteSuspended, notifyIdleness, notifyIdleSession, offerClosedReadFuture, offerFailedReadFuture, offerReadFuture, read, removeAttribute, removeAttribute, replaceAttribute, resumeRead, resumeWrite, scheduledForFlush, setAttachment, setAttribute, setAttribute, setAttributeIfAbsent, setAttributeIfAbsent, setAttributeMap, setCurrentWriteRequest, setScheduledForFlush, setWriteRequestQueue, suspendRead, suspendWrite, toString, unscheduledForFlush, updateThroughput, write, write

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

notWrittenFuture

private final WriteFuture notWrittenFuture

encoderOutput

private final AbstractProtocolEncoderOutput encoderOutput

decoderOutput

private final AbstractProtocolDecoderOutput decoderOutput

Constructor Details

ProtocolCodecSession

public ProtocolCodecSession()

Creates a new instance.

Method Details

getEncoderOutput

public ProtocolEncoderOutput getEncoderOutput()

Returns:

the ProtocolEncoderOutput that buffers IoBuffers generated by ProtocolEncoder.

getEncoderOutputQueue

public Queue<Object> getEncoderOutputQueue()

Returns:

the Queue of the buffered encoder output.

getDecoderOutput

public ProtocolDecoderOutput getDecoderOutput()

Returns:

the ProtocolEncoderOutput that buffers messages generated by ProtocolDecoder.

getDecoderOutputQueue

public Queue<Object> getDecoderOutputQueue()

Returns:

the Queue of the buffered decoder output.