activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r834195 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
Date Mon, 09 Nov 2009 19:54:37 GMT
Author: tabish
Date: Mon Nov  9 19:54:36 2009
New Revision: 834195

URL: http://svn.apache.org/viewvc?rev=834195&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-208

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs?rev=834195&r1=834194&r2=834195&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Mon Nov
 9 19:54:36 2009
@@ -252,10 +252,10 @@
             get { return brokerWireFormatInfo; }
         }
 
-		/// <summary>
-		/// Get/or set the redelivery policy for this connection.
-		/// </summary>
-		public IRedeliveryPolicy RedeliveryPolicy
+        /// <summary>
+        /// Get/or set the redelivery policy for this connection.
+        /// </summary>
+        public IRedeliveryPolicy RedeliveryPolicy
         {
             get { return this.redeliveryPolicy; }
             set { this.redeliveryPolicy = value; }
@@ -266,7 +266,7 @@
             get { return this.prefetchPolicy; }
             set { this.prefetchPolicy = value; }
         }
-        
+
         #endregion
 
         /// <summary>
@@ -363,7 +363,7 @@
         {
             this.dispatchers.Remove( id );
         }
-        
+
         internal void addProducer( ProducerId id, MessageProducer producer )
         {
             this.producers.Add( id, producer );
@@ -520,6 +520,7 @@
                     {
                         transport.Oneway(command);
                     }
+                    Tracer.Info("Oneway command sent to broker.");
                 }
                 else
                 {
@@ -528,6 +529,7 @@
                     // the broker can dispose of the object.  Allow up to 5 seconds to process.
                     Tracer.Info("Synchronously disposing of Connection.");
                     SyncRequest(command, TimeSpan.FromSeconds(5));
+                    Tracer.Info("Synchronously closed Connection.");
                 }
             }
             catch // (BrokerException)
@@ -632,14 +634,14 @@
                     IDispatcher dispatcher = (IDispatcher) dispatchers[dispatch.ConsumerId];
 
                     // Can be null when a consumer has sent a MessagePull and there was
-                    // no available message at the broker to dispatch.  
+                    // no available message at the broker to dispatch.
                     if(dispatch.Message != null)
                     {
                         dispatch.Message.ReadOnlyBody = true;
                         dispatch.Message.ReadOnlyProperties = true;
                         dispatch.Message.RedeliveryCounter = dispatch.RedeliveryCounter;
                     }
-                    
+
                     dispatcher.Dispatch(dispatch);
 
                     return;
@@ -756,7 +758,7 @@
             id.Value = Interlocked.Increment(ref localTransactionCounter);
             return id;
         }
-        
+
         protected SessionInfo CreateSessionInfo(AcknowledgementMode sessionAcknowledgementMode)
         {
             SessionInfo answer = new SessionInfo();



Mime
View raw message