[james-project] 02/28: JAMES-2794 Solve an IntelliJ warning

[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 a54fe44f4e20069415f38ecffe2949e64cf52287
Author: Benoit Tellier <btell...@linagora.com>
AuthorDate: Fri Jun 14 11:22:27 2019 +0700

    JAMES-2794 Solve an IntelliJ warning
---
 .../src/main/java/org/apache/james/queue/rabbitmq/Dequeuer.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 a2e7a7e..ee59815 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
@@ -100,14 +100,14 @@ class Dequeuer {
     private Mono<RabbitMQMailQueueItem> loadItem(AcknowledgableDelivery 
response) {
         try {
             Mail mail = loadMail(response);
-            ThrowingConsumer<Boolean> ack = ack(response, 
response.getEnvelope().getDeliveryTag(), mail);
+            ThrowingConsumer<Boolean> ack = ack(response, mail);
             return Mono.just(new RabbitMQMailQueueItem(ack, mail));
         } catch (MailQueue.MailQueueException e) {
             return Mono.error(e);
         }
     }
 
-    private ThrowingConsumer<Boolean> ack(AcknowledgableDelivery response, 
long deliveryTag, Mail mail) {
+    private ThrowingConsumer<Boolean> ack(AcknowledgableDelivery response, 
Mail mail) {
         return success -> {
             if (success) {
                 dequeueMetric.increment();


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