zmq

Class EncoderBase

java.lang.Object

zmq.EncoderBase

All Implemented Interfaces:

IEncoder

Direct Known Subclasses:

Encoder, V1Encoder

public abstract class EncoderBase
extends java.lang.Object
implements IEncoder

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	beginning
private java.nio.ByteBuffer	buffer
private int	bufferSize
private boolean	error
private int	next
private int	toWrite
private java.nio.ByteBuffer	writeBuf
private java.nio.channels.FileChannel	writeChannel
private int	writePos

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EncoderBase(int bufferSize)

Method Summary

Modifier and Type	Method and Description
protected void	encodingError()
Transfer	getData(java.nio.ByteBuffer buffer)
boolean	hasData()
boolean	isError()
protected abstract boolean	next()
protected void	nextStep(byte[] buf, int toWrite, int next, boolean beginning)
protected void	nextStep(java.nio.ByteBuffer buf, int next, boolean beginning)
protected void	nextStep(java.nio.channels.FileChannel ch, long pos, long toWrite, int next, boolean beginning)
protected void	nextStep(Msg msg, int state, boolean beginning)
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.IEncoder

setMsgSource

Field Detail

writeBuf

private java.nio.ByteBuffer writeBuf

writeChannel

private java.nio.channels.FileChannel writeChannel

writePos

private int writePos

next

private int next

beginning

private boolean beginning

toWrite

private int toWrite

buffer

private java.nio.ByteBuffer buffer

bufferSize

private int bufferSize

error

private boolean error

Constructor Detail

EncoderBase

protected EncoderBase(int bufferSize)

Method Detail

getData

public Transfer getData(java.nio.ByteBuffer buffer)

Specified by:

getData in interface IEncoder

hasData

public boolean hasData()

Specified by:

hasData in interface IEncoder

state

protected int state()

state

protected void state(int state)

encodingError

protected void encodingError()

isError

public final boolean isError()

next

protected abstract boolean next()

nextStep

protected void nextStep(Msg msg,
                        int state,
                        boolean beginning)

nextStep

protected void nextStep(byte[] buf,
                        int toWrite,
                        int next,
                        boolean beginning)

nextStep

protected void nextStep(java.nio.ByteBuffer buf,
                        int next,
                        boolean beginning)

nextStep

protected void nextStep(java.nio.channels.FileChannel ch,
                        long pos,
                        long toWrite,
                        int next,
                        boolean beginning)