| Package | Description |
|---|---|
| ds.funnel.peer | |
| ds.funnel.samples | |
| ds.funnel.topic | |
| ds.funnel.traffic.analysis | |
| ds.granules.samples.uppercase |
This package contains a simple example which flips an input string from lowercase to uppercase.
|
| Modifier and Type | Method and Description |
|---|---|
PeerGroup |
PeerManager.getPeerGroup(Topic inTopic)
Obtain the peer group for a topic, performing a lookup if it is not known.
|
PeerGroup |
PeerManagerImpl.getPeerGroup(Topic inTopic) |
void |
PeerGroupAdvert.onNeighborAdvert(MsgTopicNeighbor inEvent) |
void |
PeerGroupAdvert.onTopicAdvert(MsgTopicAdvert inEvent) |
| Modifier and Type | Method and Description |
|---|---|
static void |
NanoTimeSample.main(java.lang.String[] args) |
static void |
PublishSubscribeSample.main(java.lang.String[] args) |
static void |
NanoTimeSample.onEvent(TopicDataEvent inEvent) |
| Modifier and Type | Method and Description |
|---|---|
TopicPublisher |
Topic.publish() |
TopicPublisher |
TopicBase.publish() |
void |
TopicPublisherImpl.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
void |
TopicPublisher.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
void |
TopicPublisherImpl.sendEventData(byte[] inData,
OverlayPath... inDests) |
void |
TopicPublisher.sendEventData(byte[] inData,
OverlayPath... inDests) |
void |
TopicPublisherImpl.sendEventData(byte[] inData,
java.util.Properties inProps,
OverlayPath... inDests) |
void |
TopicPublisher.sendEventData(byte[] inData,
java.util.Properties inProps,
OverlayPath... inDests) |
TopicSubscription |
Topic.subscribe(TopicSubscriptionHandler inHandler) |
TopicSubscription |
TopicBase.subscribe(TopicSubscriptionHandler inHandler) |
| Modifier and Type | Method and Description |
|---|---|
static void |
TrafficReflector.main(java.lang.String[] args) |
static void |
TrafficPublisher.main(java.lang.String[] args) |
static void |
TrafficReflector.onEvent(TopicDataEvent inEvent,
long receiveTime)
If the inEvent was not published by this traffic reflector, republishes
the event to the traffic generation topic.
|
| Modifier and Type | Method and Description |
|---|---|
void |
UpperCaseProducer.initialize() |
void |
UpperCaseProducer.publishEvent(java.lang.String stringMsg) |