public class Receiver extends Object implements Closeable
Flux
.Modifier and Type | Class and Description |
---|---|
static class |
Receiver.AcknowledgmentContext |
Constructor and Description |
---|
Receiver() |
Receiver(ReceiverOptions options) |
Modifier and Type | Method and Description |
---|---|
protected <T> Mono<T> |
cache(Mono<T> mono) |
void |
close() |
protected void |
completeOnChannelShutdown(Channel channel,
FluxSink<?> emitter) |
Flux<Delivery> |
consumeAutoAck(String queue) |
Flux<Delivery> |
consumeAutoAck(String queue,
ConsumeOptions options) |
Flux<AcknowledgableDelivery> |
consumeManualAck(String queue) |
Flux<AcknowledgableDelivery> |
consumeManualAck(String queue,
ConsumeOptions options) |
Flux<Delivery> |
consumeNoAck(String queue) |
Flux<Delivery> |
consumeNoAck(String queue,
ConsumeOptions options) |
protected Scheduler |
createScheduler(String name) |
protected boolean |
isRecoverable(Channel channel) |
protected boolean |
isRecoverable(Connection connection) |
public Receiver()
public Receiver(ReceiverOptions options)
public Flux<Delivery> consumeNoAck(String queue, ConsumeOptions options)
protected void completeOnChannelShutdown(Channel channel, FluxSink<?> emitter)
public Flux<Delivery> consumeAutoAck(String queue, ConsumeOptions options)
public Flux<AcknowledgableDelivery> consumeManualAck(String queue)
public Flux<AcknowledgableDelivery> consumeManualAck(String queue, ConsumeOptions options)
protected boolean isRecoverable(Connection connection)
protected boolean isRecoverable(Channel channel)
public void close()
close
in interface Closeable
close
in interface AutoCloseable