This is an automated email from the ASF dual-hosted git repository.
jlmonteiro pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/main by this push:
new 07af9d901a AMQ-9365 - use ephemeral port in TcpTransportServerTest and
disable JMX in AbstractPendingMessageCursorTest to prevent conflicts in
parallel CI runs. (#1819)
07af9d901a is described below
commit 07af9d901a0c5b12618c5d8309e671d796f7e275
Author: Anmol Saxena <[email protected]>
AuthorDate: Mon Mar 23 14:21:09 2026 +0530
AMQ-9365 - use ephemeral port in TcpTransportServerTest and disable JMX in
AbstractPendingMessageCursorTest to prevent conflicts in parallel CI runs.
(#1819)
---
.../broker/region/cursors/AbstractPendingMessageCursorTest.java | 1 +
.../org/apache/activemq/transport/tcp/TcpTransportServerTest.java | 6 +++---
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java
index 6e3ca90717..44baec6a7f 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java
@@ -94,6 +94,7 @@ public abstract class AbstractPendingMessageCursorTest
extends AbstractStoreStat
protected void setUpBroker(boolean clearDataDir) throws Exception {
broker = new BrokerService();
+ broker.setUseJmx(false);
this.initPersistence(broker);
//set up a transport
TransportConnector connector = broker
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportServerTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportServerTest.java
index 46db53f15f..947935c13f 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportServerTest.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/tcp/TcpTransportServerTest.java
@@ -29,7 +29,7 @@ import java.util.HashMap;
public class TcpTransportServerTest extends TestCase{
public void testDefaultPropertiesSetOnTransport() throws Exception {
- TcpTransportServer server = (TcpTransportServer)
TransportFactory.bind(new URI("tcp://localhost:61616?trace=true"));
+ TcpTransportServer server = (TcpTransportServer)
TransportFactory.bind(new URI("tcp://localhost:0?trace=true"));
server.setTransportOption(new HashMap<String, Object>());
server.setAcceptListener(new TransportAcceptListener() {
@@ -46,8 +46,8 @@ public class TcpTransportServerTest extends TestCase{
server.start();
-
- Socket socket = new Socket("localhost", 61616);
+ int port = server.getConnectURI().getPort();
+ Socket socket = new Socket("localhost", port);
server.handleSocket(socket);
server.stop();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
