Package com.github.workerframework.util.rabbitmq

Class DefaultRabbitPublisher

java.lang.Object

com.github.workerframework.util.rabbitmq.EventPoller<QueuePublisher>

com.github.workerframework.util.rabbitmq.DefaultRabbitPublisher

All Implemented Interfaces:

Runnable

public class DefaultRabbitPublisher
extends EventPoller<QueuePublisher>

Default RabbitPublisher that uses QueuePublisher Event objects. Most implementations that wish to publish basic messages to RabbitMQ should extends this class.

Constructor Summary

Constructors

Constructor	Description
DefaultRabbitPublisher(BlockingQueue<Event<QueuePublisher>> events, QueuePublisher pubImpl)	Create a new DefaultRabbitPublisher

Method Summary

Methods inherited from class com.github.workerframework.util.rabbitmq.EventPoller

getEventQueue, run, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultRabbitPublisher

public DefaultRabbitPublisher(BlockingQueue<Event<QueuePublisher>> events,
 QueuePublisher pubImpl)

Create a new DefaultRabbitPublisher

Parameters:

events - the internal queue of events to handle

pubImpl - the implementation of the QueuePublisher