com.github.cafdataprocessing.utilities.queuehelper

Class QueueConsumerImpl

java.lang.Object

com.github.cafdataprocessing.utilities.queuehelper.QueueConsumerImpl

All Implemented Interfaces:

com.hpe.caf.util.rabbitmq.QueueConsumer

public class QueueConsumerImpl
extends Object
implements com.hpe.caf.util.rabbitmq.QueueConsumer

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

Constructor Summary

Constructors

Constructor and Description
QueueConsumerImpl(com.rabbitmq.client.Channel channel, MessageHandler messageHandler, com.hpe.caf.api.Codec codec)

Method Summary

Modifier and Type	Method and Description
void	processAck(long tag) Acknowledge a message
void	processDelivery(com.hpe.caf.util.rabbitmq.Delivery delivery) Handles a delivery and passes to message handler.
void	processDrop(long tag)
void	processReject(long tag)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueConsumerImpl

public QueueConsumerImpl(com.rabbitmq.client.Channel channel,
                         MessageHandler messageHandler,
                         com.hpe.caf.api.Codec codec)

Method Detail

processDelivery

public void processDelivery(com.hpe.caf.util.rabbitmq.Delivery delivery)

Handles a delivery and passes to message handler.

Specified by:

processDelivery in interface com.hpe.caf.util.rabbitmq.QueueConsumer

Parameters:

delivery - the newly arrived message including metadata

processAck

public void processAck(long tag)

Acknowledge a message

Specified by:

processAck in interface com.hpe.caf.util.rabbitmq.QueueConsumer

Parameters:

tag - the RabbitMQ id of the message to acknowledge

processReject

public void processReject(long tag)

Specified by:

processReject in interface com.hpe.caf.util.rabbitmq.QueueConsumer

processDrop

public void processDrop(long tag)

Specified by:

processDrop in interface com.hpe.caf.util.rabbitmq.QueueConsumer