Package dev.gmitch215.bytebox

Interface MessageBatch<T>

Type Parameters:
T - the decoded body type
public interface MessageBatch<T>
A batch of Queue messages delivered to a Consumer.
Since:
1.0.0

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    ackAll()
    Marks every message delivered regardless of how the handler ends.
    List<Message<T>>
    messages()
    Returns the messages, in best-effort publication order.
    String
    queue()
    Returns the name of the queue this batch came from.
    void
    retryAll()
    Marks every message for redelivery in a later batch.

  • Method Details

    • queue

      String queue()
      Returns the name of the queue this batch came from.
      Returns:
      the name of the queue this batch came from

    • messages

      List<Message<T>> messages()
      Returns the messages, in best-effort publication order.
      Returns:
      the messages, in best-effort publication order

    • ackAll

      void ackAll()
      Marks every message delivered regardless of how the handler ends.

    • retryAll

      void retryAll()
      Marks every message for redelivery in a later batch.