You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2022/10/13 16:24:04 UTC
[activemq-artemis] branch main updated: NO-JIRA fix AMQP acceptor property typo
This is an automated email from the ASF dual-hosted git repository.
jbertram pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new f0ecf6bc89 NO-JIRA fix AMQP acceptor property typo
f0ecf6bc89 is described below
commit f0ecf6bc8951ae81c10acdd68a3827f6a390d756
Author: Justin Bertram <jb...@apache.org>
AuthorDate: Thu Oct 13 11:23:51 2022 -0500
NO-JIRA fix AMQP acceptor property typo
---
docs/user-manual/en/amqp.md | 2 +-
.../activemq/artemis/tests/integration/routing/ElasticQueueTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/user-manual/en/amqp.md b/docs/user-manual/en/amqp.md
index f88594c0d4..58f58ef5c6 100644
--- a/docs/user-manual/en/amqp.md
+++ b/docs/user-manual/en/amqp.md
@@ -193,7 +193,7 @@ you will rely on TCP to determine when the socket needs to be closed.
This contains a real example for configuring amqpIdleTimeout:
```xml
-<acceptor name="amqp">tcp://0.0.0.0:5672?amqpIdleTimeout=0;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpMinCredits=300;directDeliver=false;batchDelay=10</acceptor>
+<acceptor name="amqp">tcp://0.0.0.0:5672?amqpIdleTimeout=0;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;directDeliver=false;batchDelay=10</acceptor>
```
## Web Sockets
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/routing/ElasticQueueTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/routing/ElasticQueueTest.java
index d1309951a8..51b0052ae4 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/routing/ElasticQueueTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/routing/ElasticQueueTest.java
@@ -436,7 +436,7 @@ public class ElasticQueueTest extends ActiveMQTestBase {
Configuration configuration = baseConfig.copy();
configuration.setName("Node" + nodeId);
configuration.setBrokerInstance(new File(getTestDirfile(), configuration.getName()));
- configuration.addAcceptorConfiguration("tcp", "tcp://localhost:" + (base_port + (nodeId)) + "?router=" + roleNameSharder + ";amqpCredits=1000;amqpMinCredits=300");
+ configuration.addAcceptorConfiguration("tcp", "tcp://localhost:" + (base_port + (nodeId)) + "?router=" + roleNameSharder + ";amqpCredits=1000;amqpLowCredits=300");
nodes.add(new EmbeddedActiveMQ().setConfiguration(configuration));
nodes.get(nodeId).setSecurityManager(customSecurityManager);
nodes.get(nodeId).setMbeanServer(mBeanServer);