diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2010-01-14 16:53:21 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2010-01-14 16:53:21 +0000 |
| commit | 7343e9fc682e96114c17e5b59b38720000234a7c (patch) | |
| tree | 0647b72de2feec8b92f190c17ecef40af396f750 /qpid/java/client/src | |
| parent | 536b07454d47c9812e4ebc4e8ac40c9b6a90845d (diff) | |
| download | qpid-python-7343e9fc682e96114c17e5b59b38720000234a7c.tar.gz | |
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
Diffstat (limited to 'qpid/java/client/src')
3 files changed, 12 insertions, 0 deletions
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); + } } |