activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1583760 - in /activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp: Connection.cs ConnectionFactory.cs
Date Tue, 01 Apr 2014 19:22:28 GMT
Author: tabish
Date: Tue Apr  1 19:22:27 2014
New Revision: 1583760

URL: http://svn.apache.org/r1583760
Log:
https://issues.apache.org/jira/browse/AMQNET-454

add patch: https://issues.apache.org/jira/secure/attachment/12638113/Apache.NMS.AMQP-23d-addTraceStatements.patch

Modified:
    activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/Connection.cs
    activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/ConnectionFactory.cs

Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/Connection.cs?rev=1583760&r1=1583759&r2=1583760&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/Connection.cs Tue Apr 
1 19:22:27 2014
@@ -335,6 +335,7 @@ namespace Apache.NMS.Amqp
                             // Allocate a Qpid connection
                             if (qpidConnection == null)
                             {
+                                Tracer.DebugFormat("Amqp: create qpid connection to: {0}",
this.BrokerUri.ToString());
                                 qpidConnection =
                                     new Org.Apache.Qpid.Messaging.Connection(
                                         brokerUri.ToString(),
@@ -351,6 +352,8 @@ namespace Apache.NMS.Amqp
                         }
                         catch (Org.Apache.Qpid.Messaging.QpidException e)
                         {
+                            Tracer.DebugFormat("Amqp: create qpid connection to: {0} failed
with {1}", 
+                                this.BrokerUri.ToString(), e.Message);
                             throw new ConnectionClosedException(e.Message);
                         }
                     }

Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/ConnectionFactory.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/ConnectionFactory.cs?rev=1583760&r1=1583759&r2=1583760&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/ConnectionFactory.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/ConnectionFactory.cs Tue
Apr  1 19:22:27 2014
@@ -31,6 +31,9 @@ namespace Apache.NMS.Amqp
     ///     * 0..N Strings specifying Qpid connection connectionProperties in the form "name:value".
     ///     * Hashtable containing properties as key/value pairs
     /// 
+    /// Connection URI are defined in
+    /// http://qpid.apache.org/releases/qpid-trunk/programming/book/connections.html#connection-url
+    /// 
     /// Example using property strings:
     /// 
     /// Uri connecturi = new Uri("amqp:localhost:5673")
@@ -42,7 +45,7 @@ namespace Apache.NMS.Amqp
     /// 
     /// Example using property table:
     /// 
-    /// Uri connecturi = new Uri("amqp:localhost:5673")
+    /// Uri connecturi = new Uri("amqp:localhost:5672")
     /// Hashtable properties = new Hashtable();
     /// properties.Add("protocol", "amqp1.0");
     /// properties.Add("reconnect_timeout", 60)
@@ -102,6 +105,7 @@ namespace Apache.NMS.Amqp
 
         public ConnectionFactory(Uri brokerUri, string clientID, params Object[] propsArray)
         {
+            Tracer.DebugFormat("Amqp: create connection factory for Uri: {0}", brokerUri.ToString());

             try
             {
                 this.brokerUri = brokerUri;
@@ -133,6 +137,7 @@ namespace Apache.NMS.Amqp
 
         public ConnectionFactory(Uri brokerUri, string clientID, Hashtable propsTable)
         {
+            Tracer.DebugFormat("Amqp: create connection factory for Uri: {0}", brokerUri.ToString());
             try
             {
                 this.brokerUri = brokerUri;



Mime
View raw message