activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1469984 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
Date Fri, 19 Apr 2013 18:31:10 GMT
Author: tabish
Date: Fri Apr 19 18:31:09 2013
New Revision: 1469984

URL: http://svn.apache.org/r1469984
Log:
fix for: https://issues.apache.org/jira/browse/AMQNET-420

Using Math.Min when it should be Math.Max

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=1469984&r1=1469983&r2=1469984&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Fri Apr
19 18:31:09 2013
@@ -72,6 +72,8 @@ namespace Apache.NMS.ActiveMQ
             this.requestTimeout = connection.RequestTimeout;
             this.dispatchAsync = connection.DispatchAsync;
             this.transactionContext = new TransactionContext(this);
+			this.exclusive = connection.ExclusiveConsumer;
+			this.retroactive = connection.UseRetroactiveConsumer;
 
             Uri brokerUri = connection.BrokerUri;
 
@@ -372,7 +374,7 @@ namespace Apache.NMS.ActiveMQ
                             consumer.FailureError = this.connection.FirstFailureError;
                             consumer.Shutdown();
                             this.lastDeliveredSequenceId =
-                                Math.Min(this.lastDeliveredSequenceId, consumer.LastDeliveredSequenceId);
+                                Math.Max(this.lastDeliveredSequenceId, consumer.LastDeliveredSequenceId);
                         }
                     }
                     consumers.Clear();



Mime
View raw message