qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject qpid-jms git commit: We should be throwing an error if properties from the URI don't apply cleanly.
Date Fri, 19 Dec 2014 23:16:08 GMT
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 <tabish121@gmail.com>
Authored: Fri Dec 19 18:15:53 2014 -0500
Committer: Timothy Bish <tabish121@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


Mime
View raw message