Uses of Class
org.acemq.workloads.scenario.ConsumerGroupNode

Packages that use ConsumerGroupNode

Package	Description
org.acemq.workloads.scenario

Uses of ConsumerGroupNode in org.acemq.workloads.scenario

Methods in org.acemq.workloads.scenario that return ConsumerGroupNode

Modifier and Type	Method	Description
ConsumerGroupNode	ConsumerGroupNode.concurrency(int concurrency)
ConsumerGroupNode	QueueNode.consumersNode()
ConsumerGroupNode	ConsumerGroupNode.enabled(boolean enabled)
ConsumerGroupNode	ConsumerGroupNode.failureRate(double fraction)
ConsumerGroupNode	ConsumerGroupNode.handlerTime(Duration handlerTime)
ConsumerGroupNode	ConsumerGroupNode.none()
ConsumerGroupNode	ConsumerGroupNode.prefetch(int prefetch)	How many unacknowledged messages each consumer may hold.

Method parameters in org.acemq.workloads.scenario with type arguments of type ConsumerGroupNode

Modifier and Type	Method	Description
QueueNode	QueueNode.consumers(Consumer<ConsumerGroupNode> spec)
Scenario	Scenario.consumers(String queueName, Consumer<ConsumerGroupNode> spec)	Attaches consumers to a queue that is already in the scenario.