Package com.github.workerframework.util.rabbitmq

Class ConsumerAckEvent

java.lang.Object

com.github.workerframework.util.rabbitmq.ConsumerAckEvent

All Implemented Interfaces:

Event<QueueConsumer>

public class ConsumerAckEvent
extends Object
implements Event<QueueConsumer>

An acknowledge Event for a Consumer.

Constructor Summary

Constructors

Constructor	Description
ConsumerAckEvent(long tag)	Create a new ConsumerAckEvent

Method Summary

Modifier and Type	Method	Description
long	getTag()
void	handleEvent(QueueConsumer target)	Trigger the action represented by this Event.

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerAckEvent

public ConsumerAckEvent(long tag)

Create a new ConsumerAckEvent

Parameters:

tag - the RabbitMQ id of the message to acknowledge

Method Details

handleEvent

public void handleEvent(QueueConsumer target)

Trigger the action represented by this Event. Acknowledges the message in a Consumer.

Specified by:

handleEvent in interface Event<QueueConsumer>

Parameters:

target - the class to perform an action on

getTag

public long getTag()

Returns:

the RabbitMQ id of the message to acknowledge by this Event