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
The following commit(s) were added to refs/heads/master by this push:
new 6a11b2ec35 RabbitMQConfiguration: add getter for
quorumQueueReplicationFactor (#2548)
6a11b2ec35 is described below
commit 6a11b2ec35dea60d23e4f8c6ea2445b5803c2e39
Author: Trần Hồng Quân <[email protected]>
AuthorDate: Thu Dec 5 21:37:08 2024 +0700
RabbitMQConfiguration: add getter for quorumQueueReplicationFactor (#2548)
---
.../james/backends/rabbitmq/RabbitMQConfiguration.java | 4 ++++
.../backends/rabbitmq/RabbitMQConfigurationTest.java | 16 ++++++++++++++++
2 files changed, 20 insertions(+)
diff --git
a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java
b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java
index 203ef0714e..0535a96a6f 100644
---
a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java
+++
b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConfiguration.java
@@ -883,6 +883,10 @@ public class RabbitMQConfiguration {
return quorumQueueDeliveryLimit;
}
+ public int getQuorumQueueReplicationFactor() {
+ return quorumQueueReplicationFactor;
+ }
+
public boolean eventBusPropagateDispatchError() {
return eventBusPropagateDispatchError;
}
diff --git
a/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java
b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java
index d18f34c84e..df747723d1 100644
---
a/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java
+++
b/backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQConfigurationTest.java
@@ -682,6 +682,22 @@ class RabbitMQConfigurationTest {
Host.from("rabbitmqhost2", 5672));
}
+ @Test
+ void shouldReturnQuorumQueueReplicationFactorWhenConfigured() {
+ PropertiesConfiguration configuration = new PropertiesConfiguration();
+ String amqpUri = "amqp://james:james@rabbitmqhost:5672";
+ configuration.addProperty("uri", amqpUri);
+ String managementUri = "http://james:james@rabbitmqhost:15672/api/";;
+ configuration.addProperty("management.uri", managementUri);
+ configuration.addProperty("management.user", DEFAULT_USER);
+ configuration.addProperty("management.password",
DEFAULT_PASSWORD_STRING);
+
+ configuration.addProperty("quorum.queues.replication.factor", 3);
+
+
assertThat(RabbitMQConfiguration.from(configuration).getQuorumQueueReplicationFactor())
+ .isEqualTo(3);
+ }
+
@Nested
class SSLConfigurationTest {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
