Class ConsumerDropEvent

java.lang.Object
com.github.workerframework.util.rabbitmq.ConsumerDropEvent
All Implemented Interfaces:
Event<QueueConsumer>

public class ConsumerDropEvent extends Object implements Event<QueueConsumer>
A message drop Event for a Consumer.
  • Constructor Details

    • ConsumerDropEvent

      public ConsumerDropEvent(long tag)
      Create a ConsumerDropEvent.
      Parameters:
      tag - the RabbitMQ id of the message to drop
  • Method Details

    • handleEvent

      public void handleEvent(QueueConsumer target)
      Trigger the action represented by this Event. Triggers a Consumer to drop the message indicated by this Event.
      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 this Event will trigger a Consumer to drop