summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2008-10-23 19:44:12 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2008-10-23 19:44:12 +0000
commitf2a61c95c3a13151ed03dd53ef802a1aa6e44c6b (patch)
tree3dc07cee9e7c6f327b989d05685182fa0a8684e9
parentf98d1258b3594fac76b2beb40c9af30e8920019b (diff)
downloadqpid-python-f2a61c95c3a13151ed03dd53ef802a1aa6e44c6b.tar.gz
This is related to QPID-1296.
I missed these two files in the previous commit. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707458 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java2
-rw-r--r--qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java2
2 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
index a7f04a2090..6480a0da76 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
@@ -140,7 +140,7 @@ public class AMQConnectionDelegate_0_10 implements AMQConnectionDelegate, Connec
}
_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)
diff --git a/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java b/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
index 82e05ba816..7411e81bd6 100644
--- a/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
+++ b/qpid/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
@@ -644,7 +644,7 @@ public class QpidBench
{
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;
}