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 | 8daf081f6b157574d9ef6b05a54115b71e74e8e9 (patch) | |
| tree | f2736dff32a60686915e5a96fd425397f2a8c5d0 /java/common/src | |
| parent | 2d630dc9aeb9902499b0c0b710bedab6bf9ce58a (diff) | |
| download | qpid-python-8daf081f6b157574d9ef6b05a54115b71e74e8e9.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/qpid@1556292 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java b/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java index b43b9d450b..0e7d061ba7 100644 --- a/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java +++ b/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"; |