diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java index 8822fc5373..0c6a14070f 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java @@ -18,6 +18,7 @@ */ package org.apache.qpid.client.failover; +import org.apache.qpid.AMQException; import org.apache.qpid.client.AMQConnection; import org.apache.qpid.client.AMQConnectionFactory; import org.apache.qpid.client.AMQDestination; @@ -1347,7 +1348,7 @@ public class FailoverBehaviourTest extends FailoverBaseCase implements Connectio * @return queue browser * @throws JMSException */ - private QueueBrowser prepareQueueBrowser(int acknowledgeMode) throws JMSException + private QueueBrowser prepareQueueBrowser(int acknowledgeMode) throws JMSException, AMQException { init(acknowledgeMode, false); _consumer.close(); @@ -1358,6 +1359,10 @@ public class FailoverBehaviourTest extends FailoverBaseCase implements Connectio { _producerSession.commit(); } + else + { + ((AMQSession)_producerSession).sync(); + } QueueBrowser browser = _consumerSession.createBrowser((Queue) _destination); return browser; |