Repository: qpid-jms Updated Branches: refs/heads/master 68d402ef1 -> b2bb91e89
Fix some issues in the test. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b2bb91e8 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b2bb91e8 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b2bb91e8 Branch: refs/heads/master Commit: b2bb91e8921e05162fb08937c6808655f8165e38 Parents: 68d402e Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Jan 20 11:14:55 2015 -0500 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Jan 20 11:15:16 2015 -0500 ---------------------------------------------------------------------- .../qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b2bb91e8/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java index e8d8fa5..0b29fea 100644 --- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java +++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/usecases/JmsLargeMessagesInGroupsTest.java @@ -27,12 +27,10 @@ import javax.jms.Queue; import javax.jms.Session; import org.apache.qpid.jms.support.AmqpTestSupport; -import org.junit.Ignore; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@Ignore("Currently fails") public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport { protected static final Logger LOG = LoggerFactory.getLogger(JmsLargeMessagesInGroupsTest.class); @@ -42,9 +40,12 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport { private static final int RECEIVE_TIMEOUT = 5000; private static final String JMSX_GROUP_ID = "JmsGroupsTest"; + private int sequenceCount = 0; + @Test public void testGroupSeqIsNeverLost() throws Exception { connection = createAmqpConnection(); + connection.start(); sendMessagesToBroker(MESSAGE_COUNT); readMessagesOnBroker(MESSAGE_COUNT); @@ -66,6 +67,8 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport { LOG.info("Message assigned JMSXGroupID := {}", gid); LOG.info("Message assigned JMSXGroupSeq := {}", seq); } + + consumer.close(); } protected void sendMessagesToBroker(int count) throws Exception { @@ -86,7 +89,7 @@ public class JmsLargeMessagesInGroupsTest extends AmqpTestSupport { BytesMessage message = session.createBytesMessage(); message.setJMSDeliveryMode(DeliveryMode.PERSISTENT); message.setStringProperty("JMSXGroupID", JMSX_GROUP_ID); - message.setIntProperty("JMSXGroupSeq", i); + message.setIntProperty("JMSXGroupSeq", ++sequenceCount); message.writeBytes(buffer); producer.send(message); } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org