com.github.cafdataprocessing.utilities.queuehelper

Class MessageHandler

java.lang.Object

com.github.cafdataprocessing.utilities.queuehelper.MessageHandler

public class MessageHandler
extends Object

Notifies all registered MessageListeners of a new message received.

Constructor Summary

Constructors

Constructor and Description
MessageHandler()

Method Summary

Modifier and Type	Method and Description
void	addListener(MessageListener listener) Register a new Listener
void	handleMessage(com.hpe.caf.api.worker.TaskMessage message, String queue) Notify all registered MessageListeners of received message.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageHandler

public MessageHandler()

Method Detail

handleMessage

public void handleMessage(com.hpe.caf.api.worker.TaskMessage message,
                          String queue)

Notify all registered MessageListeners of received message.

Parameters:

message - A TaskMessage to pass to the listeners

queue - Specifies the queue that the listener should be listening to for message to be forwarded to listener.

addListener

public void addListener(MessageListener listener)

Register a new Listener

Parameters:

listener - the MessageListener to register