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;
}