All Classes and Interfaces

Classes

Class	Description
KafkaQueuePublisher<K,T>	QueuePublisher backed by a Kafka KafkaProducer, publishing every message to a single fixed topic and partition.
KafkaQueueSubscriber<K,T>	QueueSubscriber backed by a Kafka Consumer (typically a KafkaConsumer).
MessageAggregator<T>	Thread-safe, order-retaining in-memory store for messages received by a QueueSubscriber.
QueuePublisher<T>	Abstract base for a broker-specific publisher.
QueueSubscriber<T>	Abstract base for a broker-specific subscriber/receiver.
RabbitMqQueuePublisher<T>	QueuePublisher backed by a RabbitMQ Channel, publishing every message (serialized via serializer) to a fixed exchange/routing key.
RabbitMqQueueSubscriber<T>	QueueSubscriber backed by a RabbitMQ Channel, consuming from a single queue and delivering each message body (deserialized via deserializer) to the aggregator.