Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5621 

Remove hard coded port as the bridge brokers method doesn't need the
port to be fixed.  Turn off JMX since the test doesn't use it.
This commit is contained in:
Timothy Bish 2016-05-10 10:05:05 -04:00
parent 809d5b9bc8
commit 3da9b0720e
1 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4147Test.java
View File

@ -1,4 +1,4 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.activemq.bugs; package org.apache.activemq.bugs;
import java.net.URI; import java.net.URI;
@ -37,6 +36,7 @@ import org.apache.activemq.util.Wait;
* manipulated by the remote broker. * manipulated by the remote broker.
*/ */
public class AMQ4147Test extends JmsMultipleBrokersTestSupport { public class AMQ4147Test extends JmsMultipleBrokersTestSupport {
/** /**
* This test demonstrates the bug: namely, when a message is bridged over * This test demonstrates the bug: namely, when a message is bridged over
* the VMTransport, its memory usage continues to refer to the originating * the VMTransport, its memory usage continues to refer to the originating
@ -46,10 +46,10 @@ public class AMQ4147Test extends JmsMultipleBrokersTestSupport {
*/ */
public void testVMTransportRemoteMemoryUsage() throws Exception { public void testVMTransportRemoteMemoryUsage() throws Exception {
BrokerService broker1 = createBroker(new URI( BrokerService broker1 = createBroker(new URI(
"broker:(vm://broker1)/broker1?persistent=false")); "broker:(vm://broker1)/broker1?persistent=false&useJmx=false"));
BrokerService broker2 = createBroker(new URI( BrokerService broker2 = createBroker(new URI(
"broker:(vm://broker2)/broker2?persistent=false")); "broker:(vm://broker2)/broker2?persistent=false&useJmx=false"));
startAllBrokers(); startAllBrokers();
@ -106,8 +106,7 @@ public class AMQ4147Test extends JmsMultipleBrokersTestSupport {
})); }));
assertTrue(broker2TestQueue.getMemoryUsage().getUsage() > 0); assertTrue(broker2TestQueue.getMemoryUsage().getUsage() > 0);
} finally { } finally {
// Consume the message and verify that there is no more memory // Consume the message and verify that there is no more memory usage.
// usage.
consumerProceed.release(); consumerProceed.release();
} }
@ -131,10 +130,10 @@ public class AMQ4147Test extends JmsMultipleBrokersTestSupport {
*/ */
public void testTcpTransportRemoteMemoryUsage() throws Exception { public void testTcpTransportRemoteMemoryUsage() throws Exception {
BrokerService broker1 = createBroker(new URI( BrokerService broker1 = createBroker(new URI(
"broker:(vm://broker1)/broker1?persistent=false")); "broker:(vm://broker1)/broker1?persistent=false&useJmx=false"));
BrokerService broker2 = createBroker(new URI( BrokerService broker2 = createBroker(new URI(
"broker:(tcp://localhost:61616)/broker2?persistent=false")); "broker:(tcp://localhost:0)/broker2?persistent=false&useJmx=false"));
startAllBrokers(); startAllBrokers();
@ -189,8 +188,7 @@ public class AMQ4147Test extends JmsMultipleBrokersTestSupport {
})); }));
assertTrue(broker2TestQueue.getMemoryUsage().getUsage() > 0); assertTrue(broker2TestQueue.getMemoryUsage().getUsage() > 0);
} finally { } finally {
// Consume the message and verify that there is no more memory // Consume the message and verify that there is no more memory usage.
// usage.
consumerProceed.release(); consumerProceed.release();
} }