From 7343e9fc682e96114c17e5b59b38720000234a7c Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Thu, 14 Jan 2010 16:53:21 +0000
Subject: QPID-2340 : Fix ProducerFlowControlTest to call a synchronous
 operation between sends (merged from 0.5-dev)

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899296 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 2 ++
 .../client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 5 +++++
 .../client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java  | 5 +++++
 3 files changed, 12 insertions(+)

(limited to 'qpid/java/client/src')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index 43f6fd8ad2..8a4fbe5a9b 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -1339,6 +1339,8 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic
         declareExchange(name, type, getProtocolHandler(), nowait);
     }
 
+    abstract public void sync() throws AMQException;
+
     public int getAcknowledgeMode() throws JMSException
     {
         checkNotClosed();
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index 2324d441cc..2346ab5626 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -922,6 +922,11 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic
     {
         return Serial.lt((int) currentMark, (int) deliveryTag);
     }
+    
+    public void sync() throws AMQException
+    {
+        _qpidSession.sync();
+    }
 
     public AMQMessageDelegateFactory getMessageDelegateFactory()
     {
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
index 862e23385a..9b84421612 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
@@ -584,5 +584,10 @@ public final class AMQSession_0_8 extends AMQSession<BasicMessageConsumer_0_8, B
     {
         return AMQMessageDelegateFactory.FACTORY_0_8;
     }
+    
+    public void sync() throws AMQException
+    {    
+        declareExchange(new AMQShortString("amq.direct"), new AMQShortString("direct"), false);
+    }
 
 }
-- 
cgit v1.2.1