Uses of Interface
com.rabbitmq.stream.ConsumerFlowStrategy

Packages that use ConsumerFlowStrategy

Package	Description
com.rabbitmq.stream	Main API for RabbitMQ Stream Java Client.

Uses of ConsumerFlowStrategy in com.rabbitmq.stream

Classes in com.rabbitmq.stream that implement ConsumerFlowStrategy

Modifier and Type	Class	Description
static final class	ConsumerFlowStrategy.CreditEveryNthChunkConsumerFlowStrategy	Strategy that provides the specified number of initial credits and n credits every n chunks.
static final class	ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy	Strategy that provides the specified number of initial credits and a credit on each new chunk.
static final class	ConsumerFlowStrategy.MessageCountConsumerFlowStrategy	Strategy that provides the specified number of initial credits and a credit when the specified ratio of the chunk messages are processed.

Methods in com.rabbitmq.stream that return ConsumerFlowStrategy

Modifier and Type	Method	Description
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditEveryNthChunk(int initialCredits, int n)	Strategy that provides the specified number of initial credits and n credits every n chunks.
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditOnChunkArrival()	Strategy that provides 1 initial credit and a credit on each new chunk.
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditOnChunkArrival(int initialCredits)	Strategy that provides the specified number of initial credits and a credit on each new chunk.
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditOnProcessedMessageCount(int initialCredits, double ratio)	Strategy that provides the specified number of initial credits and a credit when the specified ratio of the chunk messages are processed.
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditWhenHalfMessagesProcessed()	Strategy that provides 10 initial credits and a credit when half of the chunk messages are processed.
static ConsumerFlowStrategy	ConsumerFlowStrategy.creditWhenHalfMessagesProcessed(int initialCredits)	Strategy that provides the specified number of initial credits and a credit when half of the chunk messages are processed.

Methods in com.rabbitmq.stream with parameters of type ConsumerFlowStrategy

Modifier and Type	Method	Description
ConsumerBuilder.FlowConfiguration	ConsumerBuilder.FlowConfiguration.strategy(ConsumerFlowStrategy strategy)	Flow strategy to use