ds.granules.communication.direct

Class NIOTopicDataEvent

java.lang.Object

ds.granules.communication.direct.NIOTopicDataEvent

All Implemented Interfaces:

ds.funnel.data.msglink.MessageEvent, ds.funnel.node.event.Event, ds.funnel.topic.TopicDataEvent, ds.funnel.topic.TopicEvent

public class NIOTopicDataEvent
extends Object
implements ds.funnel.topic.TopicDataEvent

Author:

Thilina Buddhika

Constructor Summary

Constructors

Constructor and Description
NIOTopicDataEvent(byte[] data, ds.funnel.topic.Topic topic)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOTopicDataEvent

public NIOTopicDataEvent(byte[] data,
                 ds.funnel.topic.Topic topic)

Method Detail

getProperties

public Properties getProperties()

Specified by:

getProperties in interface ds.funnel.topic.TopicDataEvent

getDataSize

public int getDataSize()

Specified by:

getDataSize in interface ds.funnel.topic.TopicDataEvent

getDataBytes

public byte[] getDataBytes()

Specified by:

getDataBytes in interface ds.funnel.topic.TopicDataEvent

getDataReader

public ds.funnel.data.format.FormatReader getDataReader()

Specified by:

getDataReader in interface ds.funnel.topic.TopicDataEvent

getTopic

public ds.funnel.topic.Topic getTopic()

Specified by:

getTopic in interface ds.funnel.topic.TopicEvent

getOverlayVer

public long getOverlayVer()

Specified by:

getOverlayVer in interface ds.funnel.topic.TopicEvent

getHops

public ds.funnel.overlay.linkover.OverlayPath getHops()

Specified by:

getHops in interface ds.funnel.topic.TopicEvent

updatePath

public void updatePath(long inVersion,
              int inMemberId)

Specified by:

updatePath in interface ds.funnel.topic.TopicEvent

getDests

public List<ds.funnel.overlay.linkover.OverlayPath> getDests()

Specified by:

getDests in interface ds.funnel.topic.TopicEvent

updateDests

public void updateDests(List<ds.funnel.overlay.linkover.OverlayPath> inDests)

Specified by:

updateDests in interface ds.funnel.topic.TopicEvent

updateDestVer

public void updateDestVer(long inVersion)

Specified by:

updateDestVer in interface ds.funnel.topic.TopicEvent

getContentType

public ds.funnel.data.msglink.MessageType getContentType()

Specified by:

getContentType in interface ds.funnel.data.msglink.MessageEvent

getMessageID

public UUID getMessageID()

Specified by:

getMessageID in interface ds.funnel.data.msglink.MessageEvent

getMsgChainID

public UUID getMsgChainID()

Specified by:

getMsgChainID in interface ds.funnel.data.msglink.MessageEvent

getTimeStamp

public long getTimeStamp()

Specified by:

getTimeStamp in interface ds.funnel.data.msglink.MessageEvent

getArrivalTime

public long getArrivalTime()

Specified by:

getArrivalTime in interface ds.funnel.data.msglink.MessageEvent

getOrigin

public ds.funnel.node.NodeDetails getOrigin()

Specified by:

getOrigin in interface ds.funnel.data.msglink.MessageEvent

getLastHop

public ds.funnel.node.NodeDetails getLastHop()

Specified by:

getLastHop in interface ds.funnel.data.msglink.MessageEvent

isDropSafe

public boolean isDropSafe()

Specified by:

isDropSafe in interface ds.funnel.data.msglink.MessageEvent

getReplyLink

public ds.funnel.data.msglink.MessageLink getReplyLink()

Specified by:

getReplyLink in interface ds.funnel.data.msglink.MessageEvent

chainTo

public void chainTo(UUID inChainToID)

Specified by:

chainTo in interface ds.funnel.data.msglink.MessageEvent