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 2010/02/11 22:15:45 UTC
svn commit: r909150 - in /qpid/trunk/qpid/java:
client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java
Author: rajith
Date: Thu Feb 11 21:15:44 2010
New Revision: 909150
URL: http://svn.apache.org/viewvc?rev=909150&view=rev
Log:
Fixed an error in retrieving the SSL parameter
Added a log message in IoTransport to denote successfull creation of SSL Sender and Receiver
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java?rev=909150&r1=909149&r2=909150&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java Thu Feb 11 21:15:44 2010
@@ -171,7 +171,7 @@
brokerDetail.getProperty(BrokerDetails.OPTIONS_SASL_SERVER_NAME):
System.getProperty("qpid.sasl_server_name", "localhost");
- boolean useSSL = brokerDetail.getBooleanProperty(BrokerDetails.OPTIONS_SASL_ENCRYPTION);
+ boolean useSSL = brokerDetail.getBooleanProperty(BrokerDetails.OPTIONS_SSL);
boolean useSASLEncryption = brokerDetail.getBooleanProperty(BrokerDetails.OPTIONS_SASL_ENCRYPTION)?
brokerDetail.getBooleanProperty(BrokerDetails.OPTIONS_SASL_ENCRYPTION):
Modified: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java?rev=909150&r1=909149&r2=909150&view=diff
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java (original)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoTransport.java Thu Feb 11 21:15:44 2010
@@ -107,6 +107,8 @@
this.endpoint = binding.endpoint(sender);
this.receiver = new IoReceiver(this, new SSLReceiver(engine,binding.receiver(endpoint),(SSLSender)sender),
2*readBufferSize, timeout);
+
+ log.info("SSL Sender and Receiver initiated");
}
else
{
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org