diff options
| author | Keith Wall <kwall@apache.org> | 2014-01-07 17:58:41 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-01-07 17:58:41 +0000 |
| commit | fc2867bccfeab4126352e2ac5bec0a6e63b46b53 (patch) | |
| tree | d0774c95aad6ee1a8049d17e80b1839a9b519807 /qpid/java/common | |
| parent | f7386e281f61e6921254f6da2c9aa6850a5bf722 (diff) | |
| download | qpid-python-fc2867bccfeab4126352e2ac5bec0a6e63b46b53.tar.gz | |
QPID-5420: Restore ability to consume using BURLs specifying default exchange.
* Java Broker: Changed AbstractVirtualHost so that createExchange throws ExchangeExistException before checking for a reserved exchnage name. The effect will be that the Java Broker will again accept active declaration of the built in exchanges (amq.*, qpid.* and default).
* Java Broker: Changed the 0-8..0-9-1 ExchangeBoundHandler so that a null exchnage name is treated to mean the default exchange. This matches the behaviour of ServerSessionDelegate#exchangeBound() on the 0-10 path. This allows the Java client to query bindings on the default exchange.
* Client: Changed AbstractAMQMessageDelegate.java so that 0-10 knows the type of the default exchange when populating the JMSDestination on received messages.
* Client: Introduced system property qpid.bind_queues system property so that the exchange/queue bind side effect can be suppressed on consumer creation. Like qid.declare_exchanges and declare_queues, this system propery has effect when using BURLs. Might be useful if using a new client with older broker.
* Added new system tests.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1556292 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java b/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java index b43b9d450b..0e7d061ba7 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java @@ -230,6 +230,12 @@ public class ClientProperties * producer/consumer creation when using BindingURLs. */ public static final String QPID_DECLARE_EXCHANGES_PROP_NAME = "qpid.declare_exchanges"; + /** + * System property to control whether the client will bind queues during + * consumer creation when using BindingURLs. + */ + public static final String QPID_BIND_QUEUES_PROP_NAME = "qpid.bind_queues"; + public static final String VERIFY_QUEUE_ON_SEND = "qpid.verify_queue_on_send"; public static final String QPID_MAX_CACHED_ADDR_OPTION_STRINGS = "qpid.max_cached_address_option_strings"; |