diff options
Diffstat (limited to 'qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 10 |
1 files changed, 5 insertions, 5 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 0183c30276..3562a10f27 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 @@ -1423,7 +1423,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic checkValidDestination(destination); Queue dest = validateQueue(destination); C consumer = (C) createConsumer(dest); - + consumer.setAddressType(AMQDestination.QUEUE_TYPE); return new QueueReceiverAdaptor(dest, consumer); } @@ -1442,7 +1442,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic checkValidDestination(destination); Queue dest = validateQueue(destination); C consumer = (C) createConsumer(dest, messageSelector); - + consumer.setAddressType(AMQDestination.QUEUE_TYPE); return new QueueReceiverAdaptor(dest, consumer); } @@ -1460,7 +1460,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic checkNotClosed(); Queue dest = validateQueue(queue); C consumer = (C) createConsumer(dest); - + consumer.setAddressType(AMQDestination.QUEUE_TYPE); return new QueueReceiverAdaptor(dest, consumer); } @@ -1479,7 +1479,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic checkNotClosed(); Queue dest = validateQueue(queue); C consumer = (C) createConsumer(dest, messageSelector); - + consumer.setAddressType(AMQDestination.QUEUE_TYPE); return new QueueReceiverAdaptor(dest, consumer); } @@ -2589,7 +2589,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic ("Cannot create a durable subscription with a temporary topic: " + topic); } - if (!(topic instanceof AMQDestination && topic instanceof javax.jms.Topic)) + if (!(topic instanceof AMQDestination)) { throw new javax.jms.InvalidDestinationException( "Cannot create a subscription on topic created for another JMS Provider, class of topic provided is: " |