You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/06/26 03:28:42 UTC
[james-project] 02/28: JAMES-2794 Solve an IntelliJ warning
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 <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org