Repository: qpid-jms Updated Branches: refs/heads/master 3dbfdb7be -> 512418727
We should be throwing an error if properties from the URI don't apply cleanly. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/51241872 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/51241872 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/51241872 Branch: refs/heads/master Commit: 512418727057b0cbe7945629e487d77733dc1b26 Parents: 3dbfdb7 Author: Timothy Bish <tabish...@gmail.com> Authored: Fri Dec 19 18:15:53 2014 -0500 Committer: Timothy Bish <tabish...@gmail.com> Committed: Fri Dec 19 18:16:03 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/51241872/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java index 48d50ce..05f2ded 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java @@ -19,7 +19,6 @@ package org.apache.qpid.jms.provider.amqp; import java.io.IOException; import java.net.URI; import java.nio.ByteBuffer; -import java.util.Collections; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -127,11 +126,11 @@ public class AmqpProvider extends AbstractProvider implements TransportListener transport = createTransport(getRemoteURI()); - Map<String, String> map = Collections.emptyMap(); + Map<String, String> map = null; try { map = PropertyUtil.parseQuery(remoteURI.getQuery()); } catch (Exception e) { - IOExceptionSupport.create(e); + throw IOExceptionSupport.create(e); } Map<String, String> providerOptions = PropertyUtil.filterProperties(map, "transport."); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org