Package com.github.workerframework.util.rabbitmq

Interface QueueConsumer

All Known Implementing Classes:
WorkerQueueConsumerImpl
public interface QueueConsumer
The basic RabbitMQ consumer-side API methods.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    processAck(long tag)
    Acknowledge a message
    void
    processDelivery(Delivery delivery)
    Handle a new message from the RabbitMQ queue
    void
    processDrop(long tag)
    Drop a message
    void
    processReject(long tag)
    Reject a message back onto the queue

  • Method Details

    • processDelivery

      void processDelivery(Delivery delivery)
      Handle a new message from the RabbitMQ queue
      Parameters:
      delivery - the newly arrived message including metadata

    • processAck

      void processAck(long tag)
      Acknowledge a message
      Parameters:
      tag - the RabbitMQ id of the message to acknowledge

    • processReject

      void processReject(long tag)
      Reject a message back onto the queue
      Parameters:
      tag - the RabbitMQ id of the message to reject

    • processDrop

      void processDrop(long tag)
      Drop a message
      Parameters:
      tag - the RabbitMQ id of the message to drop