zmq

Class DecoderBase

java.lang.Object

zmq.DecoderBase

All Implemented Interfaces:

IDecoder

Direct Known Subclasses:

Decoder, V1Decoder

public abstract class DecoderBase
extends Object
implements IDecoder

Constructor Summary

Constructors

Constructor and Description
DecoderBase(int bufsize)

Method Summary

Modifier and Type	Method and Description
protected void	decodingError()
ByteBuffer	getBuffer()
MsgAllocator	getMsgAllocator()
protected abstract boolean	next()
protected void	nextStep(byte[] buf, int toRead, int state)
protected void	nextStep(ByteBuffer buf, int state)
protected void	nextStep(Msg msg, int state)
int	processBuffer(ByteBuffer buf, int size)
void	setMsgAllocator(MsgAllocator msgAllocator)
boolean	stalled()
protected int	state()
protected void	state(int state)

Methods inherited from class java.lang.Object

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

Methods inherited from interface zmq.IDecoder

setMsgSink

Constructor Detail

DecoderBase

public DecoderBase(int bufsize)

Method Detail

getBuffer

public ByteBuffer getBuffer()

Specified by:

getBuffer in interface IDecoder

processBuffer

public int processBuffer(ByteBuffer buf,
                         int size)

Specified by:

processBuffer in interface IDecoder

nextStep

protected void nextStep(Msg msg,
                        int state)

nextStep

protected void nextStep(byte[] buf,
                        int toRead,
                        int state)

nextStep

protected void nextStep(ByteBuffer buf,
                        int state)

state

protected int state()

state

protected void state(int state)

decodingError

protected void decodingError()

stalled

public boolean stalled()

Specified by:

stalled in interface IDecoder

getMsgAllocator

public MsgAllocator getMsgAllocator()

setMsgAllocator

public void setMsgAllocator(MsgAllocator msgAllocator)

next

protected abstract boolean next()