This is an automated email from the ASF dual-hosted git repository.
kao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new 767b9a36d4 JAMES-3968 Fix mail loss due to RabbitMQ ack failure
767b9a36d4 is described below
commit 767b9a36d473b5e6d195c52c7d577c776a0154c0
Author: Karsten Otto <[email protected]>
AuthorDate: Wed Feb 15 15:59:10 2023 +0100
JAMES-3968 Fix mail loss due to RabbitMQ ack failure
---
.../src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
index 658de9ba43..d3294099d0 100644
---
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
+++
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
@@ -94,7 +94,7 @@ class Enqueuer {
return (Throwable e) -> {
DeleteCondition.WithEnqueueId deleteCondition =
DeleteCondition.withEnqueueId(enqueueId, mailReference.getPartsId());
return Mono.from(mailQueueView.delete(deleteCondition))
- .thenReturn(Mono.<Void>error(e));
+ .then(Mono.<Void>error(e));
};
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
