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

Packages that use ConsumerOptions

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

Uses of ConsumerOptions in org.acemq.amqp.core

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

Modifier and Type	Method	Description
ConsumerOptions	ConsumerOptions.as(Codec codec)	Reads this queue with one named format instead of whatever arrives.
static ConsumerOptions	ConsumerOptions.defaults()
ConsumerOptions	ConsumerOptions.idempotent(IdempotencyStore store)	Handles each message at most once, by remembering which have been handled.
static ConsumerOptions	ConsumerOptions.prefetch(int prefetch)
ConsumerOptions	ConsumerOptions.requeueOnFailure()	Requeues a message when its handler fails.
ConsumerOptions	ConsumerOptions.withRetry(RetryPolicy retryPolicy)	Retries failures on a schedule, never in a sleeping handler.

Methods in org.acemq.amqp.core with parameters of type ConsumerOptions

Modifier and Type	Method	Description
<T> MessageConsumer	AceMq.consume(String queue, Class<T> payloadType, ConsumerOptions options, MessageHandler<T> handler)	Starts consuming a queue with explicit options.
ConsumerGroupBuilder<T>	ConsumerGroupBuilder.options(ConsumerOptions options)
<Q, A> Responder	AceMq.respond(String queue, Class<Q> requestType, ConsumerOptions options, Function<Q,A> handler)	As AceMq.respond(String, Class, java.util.function.Function), with consumer options.