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

This closes #751

This commit is contained in:
Clebert Suconic 2016-09-05 22:12:47 -04:00
parent 15e4799d4d ec0f05f93d
commit b13d1b0d89
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
View File

@ -58,6 +58,11 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
@Override @Override
@Before @Before
public void setUp() throws Exception { public void setUp() throws Exception {
//this system property is used to construct the executor in
//org.apache.activemq.transport.AbstractInactivityMonitor.createExecutor()
//and affects the pool's shutdown time. (default is 30 sec)
//set it to 2 to make tests shutdown quicker.
System.setProperty("org.apache.activemq.transport.AbstractInactivityMonitor.keepAliveTime", "2");
this.realStore = true; this.realStore = true;
super.setUp(); super.setUp();
} }
@ -849,7 +854,7 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
*/ */
@Test @Test
public void testSendReceiveUsingTtl() throws Exception { public void testSendReceiveUsingTtl() throws Exception {
String brokerUri = "failover://tcp://" + OWHOST + ":" + OWPORT + "?wireFormat.maxInactivityDuration=10000&wireFormat.maxInactivityDurationInitalDelay=5000"; String brokerUri = "failover://tcp://" + OWHOST + ":" + OWPORT + "?wireFormat.maxInactivityDuration=5000&wireFormat.maxInactivityDurationInitalDelay=1000";
ActiveMQConnectionFactory testFactory = new ActiveMQConnectionFactory(brokerUri); ActiveMQConnectionFactory testFactory = new ActiveMQConnectionFactory(brokerUri);
Connection sendConnection = testFactory.createConnection(); Connection sendConnection = testFactory.createConnection();
@ -858,7 +863,7 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
System.out.println("created receive connection: " + receiveConnection); System.out.println("created receive connection: " + receiveConnection);
try { try {
final int nMsg = 20; final int nMsg = 10;
final long delay = 2L; final long delay = 2L;
AsyncConsumer consumer = new AsyncConsumer(queueName, receiveConnection, Session.CLIENT_ACKNOWLEDGE, delay, nMsg); AsyncConsumer consumer = new AsyncConsumer(queueName, receiveConnection, Session.CLIENT_ACKNOWLEDGE, delay, nMsg);