fix for: https://issues.apache.org/jira/browse/AMQNET-420
Using Math.Min when it should be Math.Max
diff --git a/src/main/csharp/Session.cs b/src/main/csharp/Session.cs
index 2f1aa1c..de8aad9 100755
--- a/src/main/csharp/Session.cs
+++ b/src/main/csharp/Session.cs
@@ -72,6 +72,8 @@
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 @@
consumer.FailureError = this.connection.FirstFailureError;
consumer.Shutdown();
this.lastDeliveredSequenceId =
- Math.Min(this.lastDeliveredSequenceId, consumer.LastDeliveredSequenceId);
+ Math.Max(this.lastDeliveredSequenceId, consumer.LastDeliveredSequenceId);
}
}
consumers.Clear();