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
commit361eda748ac37a6a9930b591e4cc4ec77b5ee33a (patch)
tree0cdde3121253218d246b1ac5a0fded645721a638
parent9113054ad3ef3a35c18bd601bf61ea4f04ae60e0 (diff)
downloadqpid-python-361eda748ac37a6a9930b591e4cc4ec77b5ee33a.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/qpid@707458 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java2
-rw-r--r--java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java2
2 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
index a7f04a2090..6480a0da76 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
+++ b/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/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java b/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
index 82e05ba816..7411e81bd6 100644
--- a/java/tools/src/main/java/org/apache/qpid/tools/QpidBench.java
+++ b/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;
}