ConsumeOptions (Reactor RabbitMQ 1.5.7-SNAPSHOT)

public class ConsumeOptions
extends Object

Options for Receiver#consume* methods.

Constructors
Constructor and Description
`ConsumeOptions()`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ConsumeOptions`	`arguments(Map<String,Object> arguments)`
`ConsumeOptions`	`channelCallback(Consumer<Channel> channelCallback)`
`ConsumeOptions`	`consumerTag(String consumerTag)`
`ConsumeOptions`	`exceptionHandler(BiConsumer<Receiver.AcknowledgmentContext,Exception> exceptionHandler)`
`Map<String,Object>`	`getArguments()`
`Consumer<Channel>`	`getChannelCallback()`
`String`	`getConsumerTag()`
`BiConsumer<Receiver.AcknowledgmentContext,Exception>`	`getExceptionHandler()`
`BiFunction<Long,? super Delivery,Boolean>`	`getHookBeforeEmitBiFunction()`
`FluxSink.OverflowStrategy`	`getOverflowStrategy()`
`int`	`getQos()`
`BiFunction<Long,? super Delivery,Boolean>`	`getStopConsumingBiFunction()`
`ConsumeOptions`	`hookBeforeEmitBiFunction(BiFunction<Long,? super Delivery,Boolean> hookBeforeEmit)`
`ConsumeOptions`	`overflowStrategy(FluxSink.OverflowStrategy overflowStrategy)`
`ConsumeOptions`	`qos(int qos)`
`ConsumeOptions`	`stopConsumingBiFunction(BiFunction<Long,? super Delivery,Boolean> stopConsumingBiFunction)`

public ConsumeOptions consumerTag(String consumerTag)

public FluxSink.OverflowStrategy getOverflowStrategy()

public ConsumeOptions overflowStrategy(FluxSink.OverflowStrategy overflowStrategy)

public BiFunction<Long,? super Delivery,Boolean> getHookBeforeEmitBiFunction()

public ConsumeOptions hookBeforeEmitBiFunction(BiFunction<Long,? super Delivery,Boolean> hookBeforeEmit)

public BiFunction<Long,? super Delivery,Boolean> getStopConsumingBiFunction()

public ConsumeOptions stopConsumingBiFunction(BiFunction<Long,? super Delivery,Boolean> stopConsumingBiFunction)

public ConsumeOptions exceptionHandler(BiConsumer<Receiver.AcknowledgmentContext,Exception> exceptionHandler)

public BiConsumer<Receiver.AcknowledgmentContext,Exception> getExceptionHandler()

public ConsumeOptions channelCallback(Consumer<Channel> channelCallback)

public Consumer<Channel> getChannelCallback()

public ConsumeOptions arguments(Map<String,Object> arguments)

public Map<String,Object> getArguments()

Class ConsumeOptions