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

Packages that use PipelineBuilder

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

Uses of PipelineBuilder in org.acemq.amqp.core

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

Modifier and Type	Method	Description
PipelineBuilder<T,C>	PipelineBuilder.concurrency(int howMany)
PipelineBuilder<T,C>	PipelineBuilder.describedAs(String text)	Describes the most recently declared step, for the humans reading the logs.
PipelineBuilder<T,C>	PipelineBuilder.encodedAs(Codec codec)	Publishes the most recent step's output in a named format.
PipelineBuilder<T,C>	PipelineBuilder.idempotent(IdempotencyStore store)	Handles each message at most once at the most recently declared step.
<T> PipelineBuilder<T,T>	AceMq.pipeline(String name, Class<T> entryType)	A chain of steps, each with its own queue.
PipelineBuilder<T,C>	PipelineBuilder.prefetch(int prefetch)
<O> PipelineBuilder<T,O>	PipelineBuilder.step(String stepName, Class<O> produces, Step<C,O> handler)	Adds a step to the end of the chain.
PipelineBuilder<T,C>	PipelineBuilder.withRetry(RetryPolicy policy)	Retries the most recently declared step on a schedule, never in a sleeping handler: the engine holds a short wait and the broker's queues hold a long one.