From 7f42616db97eee3890f07188272b8d028839ebec Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 6 Jan 2009 02:07:20 +0000 Subject: QPID-1557: fixed the cpp.cluster test profile - pulled out the XA excludes into a separate excludes file - made the cluster profile exclude the XA tests - made the build system automatically set all system properties that start with profile - added a profile.clustered property that defaults to false - made the cpp.cluster test profile set the profile.clustered property to true - modified the failover tests to exclude some erroneous asserts if the broker is clustered - modified the java client to not advertize a non-zero timeout git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@731810 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/test/client/QueueBrowserAutoAckTest.java | 11 +++++++++-- .../org/apache/qpid/test/client/failover/FailoverTest.java | 8 ++++++-- 2 files changed, 15 insertions(+), 4 deletions(-) (limited to 'qpid/java/systests/src') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java index 9f3a8f3cb4..737e7aa6a7 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java @@ -47,6 +47,7 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase protected Session _clientSession; protected Queue _queue; protected static final String MESSAGE_ID_PROPERTY = "MessageIDProperty"; + protected boolean CLUSTERED = Boolean.getBoolean("profile.clustered"); public void setUp() throws Exception { @@ -452,7 +453,10 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase sendMessages("connection1", messages); - sendMessages("connection2", messages); + if (!CLUSTERED) + { + sendMessages("connection2", messages); + } checkQueueDepth(messages); @@ -517,7 +521,10 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase int messages = 50; sendMessages("connection1", messages); - sendMessages("connection2", messages); + if (!CLUSTERED) + { + sendMessages("connection2", messages); + } failBroker(); diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java index 3f610aa15d..3a1fb50725 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java @@ -60,6 +60,7 @@ public class FailoverTest extends FailoverBaseCase implements ConnectionListener private static int usedBrokers = 0; private CountDownLatch failoverComplete; private static final long DEFAULT_FAILOVER_TIME = 10000L; + private boolean CLUSTERED = Boolean.getBoolean("profile.clustered"); @Override protected void setUp() throws Exception @@ -158,9 +159,12 @@ public class FailoverTest extends FailoverBaseCase implements ConnectionListener causeFailure(DEFAULT_FAILOVER_TIME); - msg = consumer.receive(500); + if (!CLUSTERED) + { + msg = consumer.receive(500); + assertNull("Should not have received message from new broker!", msg); + } - assertNull("Should not have received message from new broker!", msg); // Check that messages still sent / received sendMessages(totalMessages, transacted); consumeMessages(totalMessages, transacted); -- cgit v1.2.1