From f0ecf6bc8951ae81c10acdd68a3827f6a390d756 Mon Sep 17 00:00:00 2001 From: Justin Bertram Date: Thu, 13 Oct 2022 11:23:51 -0500 Subject: [PATCH] NO-JIRA fix AMQP acceptor property typo --- docs/user-manual/en/amqp.md | 2 +- .../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 -tcp://0.0.0.0:5672?amqpIdleTimeout=0;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpMinCredits=300;directDeliver=false;batchDelay=10 +tcp://0.0.0.0:5672?amqpIdleTimeout=0;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;directDeliver=false;batchDelay=10 ``` ## 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);