You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/04/01 21:22:28 UTC
svn commit: r1583760 - in
/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp:
Connection.cs ConnectionFactory.cs
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;