change MaxInflight to 1

osstotalsoft · Apr 16, 2019 · 077819a · 077819a
1 parent bf69953
commit 077819a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Messaging/NBB.Messaging.Nats/NatsMessagingTopicSubscriber.cs b/src/Messaging/NBB.Messaging.Nats/NatsMessagingTopicSubscriber.cs
@@ -58,8 +58,8 @@ private Task SubscribeToTopicAsync(string subject, Func<string, Task> handler, C
             opts.ManualAcks = _subscriberOptions.AcknowledgeStrategy != MessagingAcknowledgeStrategy.Auto;
 
             //https://github.com/nats-io/go-nats-streaming#subscriber-rate-limiting
-            opts.MaxInflight = 5;
-            opts.AckWait = 40000;
+            opts.MaxInflight = 1;
+            opts.AckWait = 50000;
 
             void StanMsgHandler(object obj, StanMsgHandlerArgs args)
             {