You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/12/20 00:16:08 UTC
qpid-jms git commit: We should be throwing an error if properties
from the URI don't apply cleanly.
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 <ta...@gmail.com>
Authored: Fri Dec 19 18:15:53 2014 -0500
Committer: Timothy Bish <ta...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org