zmq

Class Decoder

java.lang.Object

zmq.DecoderBase

zmq.Decoder

All Implemented Interfaces:

IDecoder

public class Decoder
extends DecoderBase

Field Summary

Fields

Modifier and Type	Field and Description
private static int	EIGHT_BYTE_SIZE_READY
private static int	FLAGS_READY
private Msg	inProgress
private long	maxmsgsize
private static int	MESSAGE_READY
private IMsgSink	msgSink
private static int	ONE_BYTE_SIZE_READY
private byte[]	tmpbuf
private java.nio.ByteBuffer	tmpbufWrap

Fields inherited from class zmq.DecoderBase

zeroCopy

Constructor Summary

Constructors

Constructor and Description
Decoder(int bufsize, long maxmsgsize)

Method Summary

Modifier and Type	Method and Description
private boolean	eightByteSizeReady()
private boolean	flagsReady()
private boolean	messageReady()
protected boolean	next()
private boolean	oneByteSizeReady()
void	setMsgSink(IMsgSink msgSink)

Methods inherited from class zmq.DecoderBase

decodingError, getBuffer, getMsgAllocator, nextStep, nextStep, nextStep, processBuffer, setMsgAllocator, stalled, state, state

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ONE_BYTE_SIZE_READY

private static final int ONE_BYTE_SIZE_READY

See Also:

Constant Field Values

EIGHT_BYTE_SIZE_READY

private static final int EIGHT_BYTE_SIZE_READY

See Also:

Constant Field Values

FLAGS_READY

private static final int FLAGS_READY

See Also:

Constant Field Values

MESSAGE_READY

private static final int MESSAGE_READY

See Also:

Constant Field Values

tmpbuf

private final byte[] tmpbuf

tmpbufWrap

private final java.nio.ByteBuffer tmpbufWrap

inProgress

private Msg inProgress

maxmsgsize

private final long maxmsgsize

msgSink

private IMsgSink msgSink

Constructor Detail

Decoder

public Decoder(int bufsize,
               long maxmsgsize)

Method Detail

setMsgSink

public void setMsgSink(IMsgSink msgSink)

next

protected boolean next()

Specified by:

next in class DecoderBase

oneByteSizeReady

private boolean oneByteSizeReady()

eightByteSizeReady

private boolean eightByteSizeReady()

flagsReady

private boolean flagsReady()

messageReady

private boolean messageReady()