com.github.cafdataprocessing.utilities.queuehelper

Class QueueManager

java.lang.Object

com.github.cafdataprocessing.utilities.queuehelper.QueueManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class QueueManager
extends Object
implements Closeable

Utility Class that manages the connection to the rabbit server, QueueConsumer thread and publishing new tasks

Method Summary

Modifier and Type	Method and Description
void	close() Closes all open channels and connections to Rabbitmq server and stops the Consumer thread.
static com.rabbitmq.client.Connection	createRabbitConnection(com.hpe.caf.worker.queue.rabbit.RabbitWorkerQueueConfiguration configuration) Helper method to establish connection to Rabbitmq Server
static QueueManager	getInstance() Constructs or returns the QueueManager instance
MessageHandler	getMessageHandler() Returns the messageHandler property
void	publishMessage(com.hpe.caf.api.worker.TaskMessage message) Publishes a TaskMessage to the InputQueue

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static QueueManager getInstance()
                                throws Exception

Constructs or returns the QueueManager instance

Returns:

the instance of QueueManager

Throws:

Exception

publishMessage

public void publishMessage(com.hpe.caf.api.worker.TaskMessage message)
                    throws com.hpe.caf.api.CodecException,
                           IOException

Publishes a TaskMessage to the InputQueue

Parameters:

message - the message to publish

Throws:

com.hpe.caf.api.CodecException - if TaskMessage fails to serialize

IOException - if channel fails to publish the message

close

public void close()
           throws IOException

Closes all open channels and connections to Rabbitmq server and stops the Consumer thread.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

createRabbitConnection

public static com.rabbitmq.client.Connection createRabbitConnection(com.hpe.caf.worker.queue.rabbit.RabbitWorkerQueueConfiguration configuration)
                                                             throws IOException,
                                                                    TimeoutException

Helper method to establish connection to Rabbitmq Server

Parameters:

configuration - the Connection configuration

Returns:

Rabbitmq connection

Throws:

IOException

TimeoutException

getMessageHandler

public MessageHandler getMessageHandler()

Returns the messageHandler property

Returns:

the messageHandler