diff options
| author | Robert Gemmell <robbie@apache.org> | 2011-10-30 18:43:32 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2011-10-30 18:43:32 +0000 |
| commit | 6621d8de7720e1bdee7da07e9a459a9703b3f208 (patch) | |
| tree | 4b9d52beaa6c9c9b7262eaac03bca94b074439f5 /java | |
| parent | 58d51028bb1bb95512385d6bc447e0d59625deff (diff) | |
| download | qpid-python-6621d8de7720e1bdee7da07e9a459a9703b3f208.tar.gz | |
NO-JIRA: correct test issue causing failures on the Jenkins slaves during persistent runs. Make the producer use transactions to ensure messages have actually all been enqueued before consumption begins, as the test assumptions may be invalid if the havent.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1195214 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java index 53a7533869..57ff6a4fa2 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/client/AMQConnectionTest.java @@ -205,7 +205,7 @@ public class AMQConnectionTest extends QpidBrokerTestCase Session consSessA = _connection.createSession(true, Session.AUTO_ACKNOWLEDGE); MessageConsumer consumerA = consSessA.createConsumer(_queue); - Session producerSession = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Session producerSession = _connection.createSession(true, Session.SESSION_TRANSACTED); MessageProducer producer = producerSession.createProducer(_queue); // Send 3 messages @@ -213,6 +213,7 @@ public class AMQConnectionTest extends QpidBrokerTestCase { producer.send(producerSession.createTextMessage("test")); } + producerSession.commit(); MessageConsumer consumerB = null; // 0-8, 0-9, 0-9-1 prefetch is per session, not consumer. |