Interface | Description |
---|---|
BusConsumer |
Wrapper around libraries to consume from message bus
|
BusPublisher |
Class | Description |
---|---|
BusConsumer.CambriaConsumerWrapper |
Cambria based consumer
|
BusConsumer.DmaapConsumerWrapper |
MR based consumer
|
BusPublisher.CambriaPublisherWrapper |
Cambria based library publisher
|
BusPublisher.DmaapPublisherWrapper |
DmaapClient library wrapper
|
BusTopicBase | |
InlineBusTopicSink |
Transport Agnostic Bus Topic Sink to carry out the core functionality
to interact with a sink regardless if it is UEB or DMaaP.
|
InlineDmaapTopicSink |
This implementation publishes events for the associated DMAAP topic,
inline with the calling thread.
|
InlineUebTopicSink |
This implementation publishes events for the associated UEB topic,
inline with the calling thread.
|
SingleThreadedBusTopicSource |
This topic source implementation specializes in reading messages
over a bus topic source and notifying its listeners
|
SingleThreadedDmaapTopicSource |
This topic reader implementation specializes in reading messages
over DMAAP topic and notifying its listeners
|
SingleThreadedUebTopicSource |
This topic source implementation specializes in reading messages
over an UEB Bus topic source and notifying its listeners
|
Copyright © 2018. All rights reserved.