You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2023/07/06 01:30:44 UTC

[james-project] 01/02: [FIX] JAMES-3919 RabbitMQMailQueue: clean up cassandra projection when we can't publish to Rabbit

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch 3.7.x
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit f780cb5b6dd7ad2aba7bbfe3c7d4db3bb1b859b0
Author: Rene Cordier <rc...@linagora.com>
AuthorDate: Wed Jul 5 10:19:33 2023 +0700

    [FIX] JAMES-3919 RabbitMQMailQueue: clean up cassandra projection when we can't publish to Rabbit
---
 .../org/apache/james/queue/rabbitmq/view/api/FakeMailQueueView.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/api/FakeMailQueueView.java b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/api/FakeMailQueueView.java
index eecdc5c7bd..c91123bc46 100644
--- a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/api/FakeMailQueueView.java
+++ b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/api/FakeMailQueueView.java
@@ -54,8 +54,8 @@ public class FakeMailQueueView<V extends ManageableMailQueue.MailQueueItemView>
     }
 
     @Override
-    public long delete(DeleteCondition deleteCondition) {
-        return 0;
+    public Mono<Long> delete(DeleteCondition deleteCondition) {
+        return Mono.just(0L);
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org