Uses of Class
org.acemq.amqp.core.ConsumerGroup

Packages that use ConsumerGroup

Package	Description
org.acemq.amqp.core	The protocol-agnostic engine.

Uses of ConsumerGroup in org.acemq.amqp.core

Methods in org.acemq.amqp.core that return ConsumerGroup

Modifier and Type	Method	Description
ConsumerGroup	ConsumerGroup.drainTimeout(Duration timeout)
ConsumerGroup	ConsumerGroup.prefetch(int prefetch)	Changes the prefetch of every member, and of members added later.
ConsumerGroup	ConsumerGroup.scaleTo(int size)	Grows or shrinks the group.
ConsumerGroup	ConsumerGroupBuilder.start()
ConsumerGroup	Pipeline.step(String step)	The consumers running one step, so it can be scaled independently.