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/09/20 06:28:58 UTC
[james-project] branch 3.8.x updated: JAMES-3604 Do not apply queue arguments twice (#1735)
This is an automated email from the ASF dual-hosted git repository.
btellier 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 a27065d322 JAMES-3604 Do not apply queue arguments twice (#1735)
a27065d322 is described below
commit a27065d322cbeec453baaf42a4d6c1f24062b9d2
Author: Benoit TELLIER <bt...@linagora.com>
AuthorDate: Wed Sep 20 13:28:52 2023 +0700
JAMES-3604 Do not apply queue arguments twice (#1735)
---
.../james/task/eventsourcing/distributed/RabbitMQWorkQueue.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java b/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java
index 5b2435d825..8ae4d8d0e5 100644
--- a/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java
+++ b/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java
@@ -32,7 +32,6 @@ import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.util.Optional;
-import org.apache.james.backends.rabbitmq.Constants;
import org.apache.james.backends.rabbitmq.QueueArguments;
import org.apache.james.backends.rabbitmq.RabbitMQConfiguration;
import org.apache.james.backends.rabbitmq.ReceiverProvider;
@@ -130,8 +129,7 @@ public class RabbitMQWorkQueue implements WorkQueue {
.durable(true)
.arguments(rabbitMQConfiguration.workQueueArgumentsBuilder(ALLOW_QUORUM)
.singleActiveConsumer()
- .build())
- .arguments(Constants.WITH_SINGLE_ACTIVE_CONSUMER))
+ .build()))
.retryWhen(Retry.backoff(NUM_RETRIES, FIRST_BACKOFF));
Mono<AMQP.Queue.BindOk> bindQueueToExchange = sender
.bind(BindingSpecification.binding(EXCHANGE_NAME, ROUTING_KEY, QUEUE_NAME))
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org