Package com.rabbitmq.stream

Interface ConsumerFlowStrategy.Context

Enclosing interface:
ConsumerFlowStrategy
public static interface ConsumerFlowStrategy.Context
Chunk context.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    credits(int credits)
    Provide credits for the subscription.
    long
    messageCount()
    The number of messages in the chunk.

  • Method Details

    • credits

      void credits(int credits)
      Provide credits for the subscription.

      ConsumerFlowStrategy implementation should always provide 1 credit a given chunk.

      Parameters:
      credits - the number of credits provided, usually 1

    • messageCount

      long messageCount()
      The number of messages in the chunk.
      Returns:
      number of messages in the chunk