You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/11/29 23:39:30 UTC
qpid-broker-j git commit: QPID-6933: [System Tests] Fix missing test
Repository: qpid-broker-j
Updated Branches:
refs/heads/master f30122249 -> 21deb4904
QPID-6933: [System Tests] Fix missing test
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/21deb490
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/21deb490
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/21deb490
Branch: refs/heads/master
Commit: 21deb4904cb71ed83e464cd1627426fd15c9247b
Parents: f301222
Author: Alex Rudyy <or...@apache.org>
Authored: Wed Nov 29 23:39:21 2017 +0000
Committer: Alex Rudyy <or...@apache.org>
Committed: Wed Nov 29 23:39:21 2017 +0000
----------------------------------------------------------------------
.../qpid/systests/jms_1_1/transaction/CommitRollbackTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/21deb490/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/transaction/CommitRollbackTest.java
----------------------------------------------------------------------
diff --git a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/transaction/CommitRollbackTest.java b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/transaction/CommitRollbackTest.java
index d65822d..de11b97 100644
--- a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/transaction/CommitRollbackTest.java
+++ b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/transaction/CommitRollbackTest.java
@@ -433,7 +433,8 @@ public class CommitRollbackTest extends JmsTestBase
}
}
- public void testCommitWithinOnMessage() throws Exception
+ @Test
+ public void commitWithinMessageListener() throws Exception
{
final Queue queue = createQueue(getTestName());
Connection connection = getConnection();
@@ -451,7 +452,7 @@ public class CommitRollbackTest extends JmsTestBase
try
{
LOGGER.info("received message " + message);
- assertEquals("Wrong message received", message.getJMSCorrelationID(), "m1");
+ assertEquals("Unexpected message received", commitCounter.get(), message.getIntProperty(INDEX));
LOGGER.info("commit session");
session.commit();
commitCounter.incrementAndGet();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org