diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java | 7 | ||||
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java | 6 |
2 files changed, 12 insertions, 1 deletions
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 3ff7416d8f..ef0d023fb2 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 @@ -736,8 +736,13 @@ public class AMQSession_0_8 extends AMQSession<BasicMessageConsumer_0_8, BasicMe boolean isConsumer, boolean noLocal) throws AMQException { + throwUnsupportedAddressingSyntax(); + } + + void throwUnsupportedAddressingSyntax() + { throw new UnsupportedOperationException("The new addressing based syntax is " - + "not supported for AMQP 0-8/0-9 versions"); + + "not supported for AMQP 0-8/0-9/0-9-1 versions"); } protected void flushAcknowledgments() diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java index 3cb723e5a8..ed517d38a7 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java @@ -57,6 +57,12 @@ public class BasicMessageProducer_0_8 extends BasicMessageProducer void declareDestination(AMQDestination destination) { + + if (destination.getDestSyntax() == AMQDestination.DestSyntax.ADDR) + { + getSession().throwUnsupportedAddressingSyntax(); + } + if(getSession().isDeclareExchanges()) { final MethodRegistry methodRegistry = getSession().getMethodRegistry(); |