Skip to content
This repository was archived by the owner on Sep 26, 2025. It is now read-only.

Commit a9fa405

Browse files
authored
Merge pull request #54 from pmackowski/doc-consume-auto-ack-typo
documentaion connection failure section fix
2 parents c6187ee + 0ebf04c commit a9fa405

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/reactor/rabbitmq/docs/ApiGuideReceiver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ void ackExceptionHandler() {
7474
// tag::auto-ack-retry-settings[]
7575
Flux<Delivery> inboundFlux = RabbitFlux
7676
.createReceiver()
77-
.consumeNoAck("reactive.queue", new ConsumeOptions()
77+
.consumeAutoAck("reactive.queue", new ConsumeOptions()
7878
.exceptionHandler(new ExceptionHandlers.RetryAcknowledgmentExceptionHandler(
7979
Duration.ofSeconds(20), Duration.ofMillis(500), // <1>
8080
ExceptionHandlers.CONNECTION_RECOVERY_PREDICATE

0 commit comments

Comments
 (0)