[james-project] 19/28: JAMES-2794 ack should update the view using an EnqueueId reference

[btellier]

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

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

commit edd328029485c64a63ef8dbc883f3db881c6197f
Author: Benoit Tellier <btell...@linagora.com>
AuthorDate: Tue Jun 25 08:29:30 2019 +0700

    JAMES-2794 ack should update the view using an EnqueueId reference
---
 .../src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java
 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java
index 94b803c..ae9829e 100644
--- 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java
+++ 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java
@@ -120,7 +120,7 @@ class Dequeuer {
             if (success) {
                 dequeueMetric.increment();
                 response.ack();
-                
mailQueueView.delete(DeleteCondition.withName(mailWithEnqueueId.getMail().getName()));
+                
mailQueueView.delete(DeleteCondition.withEnqueueId(mailWithEnqueueId.getEnqueueId()));
             } else {
                 response.nack(REQUEUE);
             }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org