This is an automated email from the ASF dual-hosted git repository.
kao pushed a commit to branch 3.7.x
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/3.7.x by this push:
new 2de17e1bba JAMES-3968 Fix mail loss due to RabbitMQ ack failure
2de17e1bba is described below
commit 2de17e1bba42a25fc4482006ba32bfc831ab30d2
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 b6d97b74fc..1820249b9f 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
@@ -91,7 +91,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]
