A C G H M P Q R

A

addListener(MessageListener) - Method in class com.github.cafdataprocessing.utilities.queuehelper.MessageHandler

Register a new Listener

C

close() - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueManager

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

com.github.cafdataprocessing.utilities.queuehelper - package com.github.cafdataprocessing.utilities.queuehelper

createRabbitConnection(RabbitWorkerQueueConfiguration) - Static method in class com.github.cafdataprocessing.utilities.queuehelper.QueueManager

Helper method to establish connection to Rabbitmq Server

G

getBackOffInterval() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getConsumeQueueNames() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getHost() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getInstance() - Static method in class com.github.cafdataprocessing.utilities.queuehelper.QueueManager

Constructs or returns the QueueManager instance

getInstance() - Static method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitServices

Provides access to the single instance of RabbitServices in application.

getMaxBackoff() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getMaxPriority() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getMaxRetryAttempts() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getMessageHandler() - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueManager

Returns the messageHandler property

getPassword() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getPort() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getPublishQueue() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

getQueues() - Method in interface com.github.cafdataprocessing.utilities.queuehelper.MessageListener

Returns the queues the listener wants to receive messages from.

getRabbitProperties() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitServices

getRabbitQueueConfiguration() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitServices

getUser() - Method in class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

H

handleMessage(TaskMessage, String) - Method in class com.github.cafdataprocessing.utilities.queuehelper.MessageHandler

Notify all registered MessageListeners of received message.

M

MessageHandler - Class in com.github.cafdataprocessing.utilities.queuehelper

Notifies all registered MessageListeners of a new message received.

MessageHandler() - Constructor for class com.github.cafdataprocessing.utilities.queuehelper.MessageHandler

MessageListener - Interface in com.github.cafdataprocessing.utilities.queuehelper

Interface for Message Listeners

messageReceived(TaskMessage) - Method in interface com.github.cafdataprocessing.utilities.queuehelper.MessageListener

Method called on a listener when a task message is received.

P

processAck(long) - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

Acknowledge a message

processDelivery(Delivery) - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

Handles a delivery and passes to message handler.

processDrop(long) - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

processReject(long) - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

publishMessage(TaskMessage) - Method in class com.github.cafdataprocessing.utilities.queuehelper.QueueManager

Publishes a TaskMessage to the InputQueue

Q

QueueConsumerImpl - Class in com.github.cafdataprocessing.utilities.queuehelper

Implementation of the QueueConsumer interface to read messages from a rabbitmq queue.

QueueConsumerImpl(Channel, MessageHandler, Codec) - Constructor for class com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

QueueManager - Class in com.github.cafdataprocessing.utilities.queuehelper

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

R

RabbitProperties - Class in com.github.cafdataprocessing.utilities.queuehelper

Properties describing connection to RabbitMQ.

RabbitProperties() - Constructor for class com.github.cafdataprocessing.utilities.queuehelper.RabbitProperties

RabbitServices - Class in com.github.cafdataprocessing.utilities.queuehelper

Provides access to rabbit configuration read from environment.

A C G H M P Q R