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

Add one fix from: https://issues.apache.org/jira/browse/AMQ-4268 

need to ensure at least one consumer cycle to ensure the redelivery flag is set. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1437691 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-01-23 20:09:43 +00:00
parent 0dfa5f483c
commit 2dd8b61a4b
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriptionOfflineTest.java
View File

@ -1558,7 +1558,6 @@ public class DurableSubscriptionOfflineTest extends org.apache.activemq.TestSupp
} }
} }
public void testRedeliveryFlag() throws Exception { public void testRedeliveryFlag() throws Exception {
Connection con; Connection con;
@ -1625,7 +1624,7 @@ public class DurableSubscriptionOfflineTest extends org.apache.activemq.TestSupp
con.close(); con.close();
// peek all // peek all
for (int j = 0; j < random.nextInt(10); j++) { for (int j = -1; j < random.nextInt(10); j++) {
con = createConnection(clientId); con = createConnection(clientId);
session = con.createSession(false, Session.CLIENT_ACKNOWLEDGE); session = con.createSession(false, Session.CLIENT_ACKNOWLEDGE);
consumer = session.createDurableSubscriber(topic, "SubsId", "filter = 'true'", true); consumer = session.createDurableSubscriber(topic, "SubsId", "filter = 'true'", true);
@ -1638,7 +1637,6 @@ public class DurableSubscriptionOfflineTest extends org.apache.activemq.TestSupp
con.close(); con.close();
} }
// consume remaining // consume remaining
con = createConnection(clientId); con = createConnection(clientId);
session = con.createSession(false, Session.CLIENT_ACKNOWLEDGE); session = con.createSession(false, Session.CLIENT_ACKNOWLEDGE);