ds.funnel.topic

Class TopicPublisherImpl

java.lang.Object

ds.funnel.topic.TopicPublisherImpl

All Implemented Interfaces:

PeerGroupUtilizer, TopicPublisher

public class TopicPublisherImpl
extends java.lang.Object
implements TopicPublisher, PeerGroupUtilizer

Constructor Summary

Constructors

Constructor and Description
TopicPublisherImpl(PeerGroup inGroup)

Method Summary

Modifier and Type	Method and Description
void	cancel()
Topic	getTopic()
void	onEvent(TopicEvent inEvent) Called by the group to pass incoming events to the utilizer.
void	sendEvent(TopicDataEvent inEvent, OverlayPath... inDests)
void	sendEventData(byte[] inData, OverlayPath... inDests)
void	sendEventData(byte[] inData, java.util.Properties inProps, OverlayPath... inDests)

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPublisherImpl

public TopicPublisherImpl(PeerGroup inGroup)

Method Detail

getTopic

public Topic getTopic()

Specified by:

getTopic in interface TopicPublisher

sendEventData

public void sendEventData(byte[] inData,
                          OverlayPath... inDests)
                   throws TopicException

Specified by:

sendEventData in interface TopicPublisher

Throws:

TopicException

sendEventData

public void sendEventData(byte[] inData,
                          java.util.Properties inProps,
                          OverlayPath... inDests)
                   throws TopicException

Specified by:

sendEventData in interface TopicPublisher

Throws:

TopicException

sendEvent

public void sendEvent(TopicDataEvent inEvent,
                      OverlayPath... inDests)
               throws TopicException

Specified by:

sendEvent in interface TopicPublisher

Throws:

TopicException

cancel

public void cancel()

Specified by:

cancel in interface TopicPublisher

onEvent

public void onEvent(TopicEvent inEvent)

Description copied from interface: PeerGroupUtilizer

Called by the group to pass incoming events to the utilizer.

Specified by:

onEvent in interface PeerGroupUtilizer

Parameters:

inEvent - - An event sent to the group.