Package com.github.workerframework.queues.rabbit

package com.github.workerframework.queues.rabbit

Class	Description
RabbitMetricsReporter
RabbitTaskInformation
RabbitWorkerQueue	This implementation uses a separate thread for a consumer and producer, each with their own Channel.
RabbitWorkerQueueConfiguration	Configuration for the worker-queue-rabbit module.
RabbitWorkerQueueProvider
WorkerConnectionListener	Trivial ConnectionListener primarily to handle aborting in-progress tasks when the RabbitMQ connection is recovered - this is because RabbitMQ will automatically re-queue the message when it detected our client dropped, and we don't want to produce a result for these tasks running when the connection dropped to try and avoid duplicate results.
WorkerPublisher	A publisher that publishes to a specific queue and acknowledges another message subsequent to publishing.
WorkerPublisherImpl	A RabbitMQ publisher that uses a ConfirmListener, sending data as plain text with headers.
WorkerPublishQueueEvent	Event for publishing via a WorkerPublisher.
WorkerQueueConsumerImpl	QueueConsumer implementation for a WorkerQueue.