public class ReceivedPacket extends Object
Constructor and Description |
---|
ReceivedPacket(ByteBuffer multicastPacket,
FeedType feedType,
ConnectionType connectionType)
Constructor.
|
ReceivedPacket(ByteBuffer multicastPacket,
FeedType feedType,
ConnectionType connectionType,
biz.onixs.cme.sbe.ByteDecoder decoder)
Constructor.
|
ReceivedPacket(ReceivedPacket src)
Copy constructor.
|
Modifier and Type | Method and Description |
---|---|
ConnectionType |
getConnectionType()
Get connection type.
|
FeedType |
getFeedType()
Get feed type.
|
byte[] |
getRaw()
Get received bytes.
|
long |
getReceivingTimestamp()
Get receiving timestamp.
|
long |
getSeqNum()
Gets packet sequence number.
|
long |
getTimeStamp()
Gets packet sending time.
|
biz.onixs.cme.sbe.IMessage |
next()
Get next message in packet if exist.
|
void |
resetReceivingTimestamp()
Reset receiving timestamp.
|
void |
rewind()
Position message iterator to the beginning of the packet.
|
void |
setDecoder(biz.onixs.cme.sbe.ByteDecoder decoder)
Set SBE decoder to decode message.
|
String |
toString()
Convert object to string representation.
|
public ReceivedPacket(ByteBuffer multicastPacket, FeedType feedType, ConnectionType connectionType, biz.onixs.cme.sbe.ByteDecoder decoder) throws IOException
multicastPacket
- received bytesfeedType
- feed typedecoder
- SBE decoderIOException
- underlying byte array access exceptionpublic ReceivedPacket(ByteBuffer multicastPacket, FeedType feedType, ConnectionType connectionType) throws IOException
multicastPacket
- received bytesfeedType
- feed typeIOException
- underlying byte array access exceptionpublic ReceivedPacket(ReceivedPacket src) throws IOException
src
- source packetIOException
- underlying byte array access exceptionpublic void rewind()
public biz.onixs.cme.sbe.IMessage next()
public long getSeqNum()
public long getTimeStamp()
public FeedType getFeedType()
public ConnectionType getConnectionType()
public long getReceivingTimestamp()
public void setDecoder(biz.onixs.cme.sbe.ByteDecoder decoder)
decoder
- SBE decoder. Can be obtained via CmeMdHandler instance.public void resetReceivingTimestamp()
public byte[] getRaw()
Copyright © 2010–2020 Onix Solutions. All rights reserved.