public class NIOTopicDataEvent extends Object implements ds.funnel.topic.TopicDataEvent
Constructor and Description |
---|
NIOTopicDataEvent(byte[] data,
ds.funnel.topic.Topic topic) |
Modifier and Type | Method and Description |
---|---|
void |
chainTo(UUID inChainToID) |
long |
getArrivalTime() |
ds.funnel.data.msglink.MessageType |
getContentType() |
byte[] |
getDataBytes() |
ds.funnel.data.format.FormatReader |
getDataReader() |
int |
getDataSize() |
List<ds.funnel.overlay.linkover.OverlayPath> |
getDests() |
ds.funnel.overlay.linkover.OverlayPath |
getHops() |
ds.funnel.node.NodeDetails |
getLastHop() |
UUID |
getMessageID() |
UUID |
getMsgChainID() |
ds.funnel.node.NodeDetails |
getOrigin() |
long |
getOverlayVer() |
Properties |
getProperties() |
ds.funnel.data.msglink.MessageLink |
getReplyLink() |
long |
getTimeStamp() |
ds.funnel.topic.Topic |
getTopic() |
boolean |
isDropSafe() |
void |
updateDests(List<ds.funnel.overlay.linkover.OverlayPath> inDests) |
void |
updateDestVer(long inVersion) |
void |
updatePath(long inVersion,
int inMemberId) |
public NIOTopicDataEvent(byte[] data, ds.funnel.topic.Topic topic)
public Properties getProperties()
getProperties
in interface ds.funnel.topic.TopicDataEvent
public int getDataSize()
getDataSize
in interface ds.funnel.topic.TopicDataEvent
public byte[] getDataBytes()
getDataBytes
in interface ds.funnel.topic.TopicDataEvent
public ds.funnel.data.format.FormatReader getDataReader()
getDataReader
in interface ds.funnel.topic.TopicDataEvent
public ds.funnel.topic.Topic getTopic()
getTopic
in interface ds.funnel.topic.TopicEvent
public long getOverlayVer()
getOverlayVer
in interface ds.funnel.topic.TopicEvent
public ds.funnel.overlay.linkover.OverlayPath getHops()
getHops
in interface ds.funnel.topic.TopicEvent
public void updatePath(long inVersion, int inMemberId)
updatePath
in interface ds.funnel.topic.TopicEvent
public List<ds.funnel.overlay.linkover.OverlayPath> getDests()
getDests
in interface ds.funnel.topic.TopicEvent
public void updateDests(List<ds.funnel.overlay.linkover.OverlayPath> inDests)
updateDests
in interface ds.funnel.topic.TopicEvent
public void updateDestVer(long inVersion)
updateDestVer
in interface ds.funnel.topic.TopicEvent
public ds.funnel.data.msglink.MessageType getContentType()
getContentType
in interface ds.funnel.data.msglink.MessageEvent
public UUID getMessageID()
getMessageID
in interface ds.funnel.data.msglink.MessageEvent
public UUID getMsgChainID()
getMsgChainID
in interface ds.funnel.data.msglink.MessageEvent
public long getTimeStamp()
getTimeStamp
in interface ds.funnel.data.msglink.MessageEvent
public long getArrivalTime()
getArrivalTime
in interface ds.funnel.data.msglink.MessageEvent
public ds.funnel.node.NodeDetails getOrigin()
getOrigin
in interface ds.funnel.data.msglink.MessageEvent
public ds.funnel.node.NodeDetails getLastHop()
getLastHop
in interface ds.funnel.data.msglink.MessageEvent
public boolean isDropSafe()
isDropSafe
in interface ds.funnel.data.msglink.MessageEvent
public ds.funnel.data.msglink.MessageLink getReplyLink()
getReplyLink
in interface ds.funnel.data.msglink.MessageEvent
public void chainTo(UUID inChainToID)
chainTo
in interface ds.funnel.data.msglink.MessageEvent
Copyright © 2015. All rights reserved.