Package com.activeviam.io.messaging
-
Interface Summary Interface Description IMessagingConsumer Contract for implementing consumers for remote messaging topic or queue.IMessagingTopic Contract for a topic of the Messaging Source. -
Class Summary Class Description MessagingSource MessagingSource to poll topics in a remote messaging system, for eg.MessagingTopic Topic that listens for records from a messaging system, for eg.TxSizeController Drain the AP topic's internal publishQueue, and submit records to datastore.TxSizeController.LogMessageOutputStream TxSizeController.PublishTask<E>