This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch 3.8.x
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/3.8.x by this push:
new b84731f893 JAMES-3968 Fix mail loss due to RabbitMQ ack failure (#1915)
b84731f893 is described below
commit b84731f893a233a1158cd5a3199a07bff3aa1460
Author: Benoit TELLIER <[email protected]>
AuthorDate: Fri Jan 12 03:13:32 2024 +0100
JAMES-3968 Fix mail loss due to RabbitMQ ack failure (#1915)
---
.../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]
