You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/08/26 19:14:11 UTC
activemq-artemis git commit: removing System.exit from test
Repository: activemq-artemis
Updated Branches:
refs/heads/master 3668050c8 -> 6a1a1b085
removing System.exit from test
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6a1a1b08
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6a1a1b08
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6a1a1b08
Branch: refs/heads/master
Commit: 6a1a1b085fe1536e088b038677a46318b774a3f0
Parents: 3668050
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri Aug 26 15:11:48 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri Aug 26 15:11:48 2016 -0400
----------------------------------------------------------------------
.../tests/integration/client/PagingTest.java | 31 ++++++++------------
1 file changed, 12 insertions(+), 19 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6a1a1b08/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
index b93afb7..14d9da6 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java
@@ -180,29 +180,22 @@ public class PagingTest extends ActiveMQTestBase {
Assert.assertNotNull(message2);
}
- try {
- if (ad > -1) {
- session.commit();
- }
- else {
- session.rollback();
- for (int i = 0; i < 100; i++) {
- ClientMessage message2 = consumer.receive(LargeMessageTest.RECEIVE_WAIT_TIME);
-
- Assert.assertNotNull(message2);
+ if (ad > -1) {
+ session.commit();
+ }
+ else {
+ session.rollback();
+ for (int i = 0; i < 100; i++) {
+ ClientMessage message2 = consumer.receive(LargeMessageTest.RECEIVE_WAIT_TIME);
- message2.acknowledge();
+ Assert.assertNotNull(message2);
- Assert.assertNotNull(message2);
- }
- session.commit();
+ message2.acknowledge();
+ Assert.assertNotNull(message2);
}
- }
- catch (Throwable e) {
- System.err.println("here!!!!!!!");
- e.printStackTrace();
- System.exit(-1);
+ session.commit();
+
}
consumer.close();