com.github.cafdataprocessing.utilities.tasksubmitter.services

Class QueueServices

java.lang.Object

com.github.cafdataprocessing.utilities.tasksubmitter.services.QueueServices

public class QueueServices
extends Object

Initialises objects for communication with RabbitMQ and provides access to submit tasks to the queue through these.

Constructor Summary

Constructors

Constructor and Description
QueueServices()

Method Summary

Modifier and Type	Method and Description
static void	publishAllMessages(List<FileAndTaskMessage> taskMessages)
static void	publishMessage(FileAndTaskMessage fileWithTaskMessage)
static void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueServices

public QueueServices()

Method Detail

publishAllMessages

public static void publishAllMessages(List<FileAndTaskMessage> taskMessages)
                               throws IOException,
                                      com.hpe.caf.api.CodecException

Throws:

IOException

com.hpe.caf.api.CodecException

publishMessage

public static void publishMessage(FileAndTaskMessage fileWithTaskMessage)
                           throws com.hpe.caf.api.CodecException,
                                  IOException

Throws:

com.hpe.caf.api.CodecException

IOException

shutdown

public static void shutdown()
                     throws IOException

Throws:

IOException