You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2008/10/23 21:44:13 UTC

svn commit: r707458 - in /incubator/qpid/trunk/qpid/java: client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java tools/src/main/java/org/apache/qpid/tools/QpidBench.java

Author: rajith
Date: Thu Oct 23 12:44:12 2008
New Revision: 707458

URL: http://svn.apache.org/viewvc?rev=707458&view=rev
Log:
This is related to QPID-1296.
I missed these two files in the previous commit.

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
    incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java?rev=707458&r1=707457&r2=707458&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java Thu Oct 23 12:44:12 2008
@@ -140,7 +140,7 @@
             }
             _qpidConnection.setConnectionListener(this);
             _qpidConnection.connect(brokerDetail.getHost(), brokerDetail.getPort(), _conn.getVirtualHost(),
-                                    _conn.getUsername(), _conn.getPassword());
+                                    _conn.getUsername(), _conn.getPassword(), brokerDetail.useSSL());
             _conn._connected = true;
         }
         catch(ProtocolVersionException pe)

Modified: incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java?rev=707458&r1=707457&r2=707458&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java (original)
+++ incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java Thu Oct 23 12:44:12 2008
@@ -644,7 +644,7 @@
     {
         org.apache.qpid.transport.Connection conn =
             new org.apache.qpid.transport.Connection();
-        conn.connect(opts.broker, opts.port, null, "guest", "guest");
+        conn.connect(opts.broker, opts.port, null, "guest", "guest",false);
         return conn;
     }