diff options
Diffstat (limited to 'java/client/src')
3 files changed, 12 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 43f6fd8ad2..8a4fbe5a9b 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/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/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index 2324d441cc..2346ab5626 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/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/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java index 862e23385a..9b84421612 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java +++ b/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); + } } |