com.marketfactory.mfclient.internal.mfproto

Class MFProtoInputBufferImpl

java.lang.Object

com.marketfactory.mfclient.internal.mfproto.MFProtoInputBufferImpl

All Implemented Interfaces:

MFProtoInputBuffer

Direct Known Subclasses:

MFProtoInputBufferMarketDataImpl, MFProtoInputBufferStpBookingImpl, MFProtoInputBufferTradeDateRolloverImpl, MFProtoInputBufferTradingImpl

public class MFProtoInputBufferImpl
extends java.lang.Object
implements MFProtoInputBuffer

Field Summary

Fields

Modifier and Type	Field and Description
protected uk.co.real_logic.agrona.DirectBuffer	directBuffer

Method Summary

Modifier and Type	Method and Description
long	getSendingTime()
boolean	hasNextMessage() Indicates more messages are available to process in the packet.
boolean	hasNextPacket() Indicates more packets are available to process in the buffer.
protected void	next() Increments to the next message.
mfframing.MessageHeaderDecoder	nextHdr() Retrieves the next header.
void	readFrom(java.nio.channels.ReadableByteChannel channel)
void	reset()
void	skipCurrentMessage()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

directBuffer

protected final uk.co.real_logic.agrona.DirectBuffer directBuffer

Method Detail

reset

public void reset()

Specified by:

reset in interface MFProtoInputBuffer

hasNextPacket

public boolean hasNextPacket()

Description copied from interface: MFProtoInputBuffer

Indicates more packets are available to process in the buffer.

Specified by:

hasNextPacket in interface MFProtoInputBuffer

Returns:

True if there is a message to be processed. False if there are no messages to be processed.

hasNextMessage

public boolean hasNextMessage()

Description copied from interface: MFProtoInputBuffer

Indicates more messages are available to process in the packet.

Specified by:

hasNextMessage in interface MFProtoInputBuffer

Returns:

True if there is a message to be processed. False if there are no messages to be processed.

nextHdr

public final mfframing.MessageHeaderDecoder nextHdr()

Description copied from interface: MFProtoInputBuffer

Retrieves the next header.

Specified by:

nextHdr in interface MFProtoInputBuffer

getSendingTime

public long getSendingTime()

Specified by:

getSendingTime in interface MFProtoInputBuffer

skipCurrentMessage

public void skipCurrentMessage()

Specified by:

skipCurrentMessage in interface MFProtoInputBuffer

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

readFrom

public void readFrom(java.nio.channels.ReadableByteChannel channel)
              throws java.io.IOException

Specified by:

readFrom in interface MFProtoInputBuffer

Throws:

java.io.IOException

next

protected void next()

Increments to the next message.