diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2008-02-27 19:56:58 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2008-02-27 19:56:58 +0000 |
| commit | e5baeccc520bb72063ea603f1c0ecdc07fe7c519 (patch) | |
| tree | f9458c69620c31002c89ad7379fddbf66ef1d4cf /java/common | |
| parent | cc1a3931c70ac1e78b33834c2d015241bf453ff7 (diff) | |
| download | qpid-python-e5baeccc520bb72063ea603f1c0ecdc07fe7c519.tar.gz | |
Correct the constant OPTION_BINDING_KEY that resulted in a test case failure
Modified the AMQBindingURL to fix an error in the toString method
Added more test cases to the main method in the BindingURLParser for quick testing, these cases are also present as unit tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@631695 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common')
3 files changed, 24 insertions, 15 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java b/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java index 42f125920c..998242925c 100644 --- a/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java +++ b/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java @@ -209,20 +209,28 @@ public class AMQBindingURL implements BindingURL sb.append(URLHelper.printOptions(_options)); // temp hack - if (sb.toString().indexOf("?") == -1) + if (getRoutingKey() == null || getRoutingKey().toString().equals("")) { - sb.append("?"); + + if (sb.toString().indexOf("?") == -1) + { + sb.append("?"); + } + else + { + sb.append("&"); + } + + for (AMQShortString key :_bindingKeys) + { + sb.append(BindingURL.OPTION_BINDING_KEY).append("='").append(key.toString()).append("'&"); + } + + return sb.toString().substring(0,sb.toString().length()-1); } else { - sb.append("&"); + return sb.toString(); } - - for (AMQShortString key :_bindingKeys) - { - sb.append("bindingKey='").append(key.toString()).append("'&"); - } - - return sb.toString().substring(0,sb.toString().length()-1); } } diff --git a/java/common/src/main/java/org/apache/qpid/url/BindingURL.java b/java/common/src/main/java/org/apache/qpid/url/BindingURL.java index c4346d721b..25450fea64 100644 --- a/java/common/src/main/java/org/apache/qpid/url/BindingURL.java +++ b/java/common/src/main/java/org/apache/qpid/url/BindingURL.java @@ -34,7 +34,7 @@ public interface BindingURL public static final String OPTION_CLIENTID = "clientid"; public static final String OPTION_SUBSCRIPTION = "subscription"; public static final String OPTION_ROUTING_KEY = "routingkey"; - public static final String OPTION_BINDING_KEY = "bindingKey"; + public static final String OPTION_BINDING_KEY = "bindingkey"; String getURL(); diff --git a/java/common/src/main/java/org/apache/qpid/url/BindingURLParser.java b/java/common/src/main/java/org/apache/qpid/url/BindingURLParser.java index f7e0b53cb1..5d26e7e65b 100644 --- a/java/common/src/main/java/org/apache/qpid/url/BindingURLParser.java +++ b/java/common/src/main/java/org/apache/qpid/url/BindingURLParser.java @@ -414,13 +414,14 @@ public class BindingURLParser String[] urls = new String[] { "topic://amq.topic//myTopic?routingkey='stocks.#'", - "topic://amq.topic/message_queue?bindingKey='usa.*'&bindingKey='control',exclusive='true'", - "topic://amq.topic//?bindingKey='usa.*',bindingKey='control',exclusive='true'", - "direct://amq.direct/dummyDest/myQueue?routingKey='abc.*'", + "topic://amq.topic/message_queue?bindingkey='usa.*'&bindingkey='control',exclusive='true'", + "topic://amq.topic//?bindingKey='usa.*',bindingkey='control',exclusive='true'", + "direct://amq.direct/dummyDest/myQueue?routingkey='abc.*'", "exchange.Class://exchangeName/Destination/Queue", "exchangeClass://exchangeName/Destination/?option='value',option2='value2'", "IBMPerfQueue1?durable='true'", - "exchangeClass://exchangeName/Destination/?bindingKey='key1',bindingKey='key2'" + "exchangeClass://exchangeName/Destination/?bindingkey='key1',bindingkey='key2'", + "exchangeClass://exchangeName/Destination/?bindingkey='key1'&routingkey='key2'" }; try |