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 2009/11/09 20:54:37 UTC
svn commit: r834195 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
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();