Actually fixed #29

2021-06-25 09:35:26 +02:00 · 2021-06-25 09:35:26 +02:00 · bbfb580a97
parent e33201dc17
commit bbfb580a97
1 changed files with 2 additions and 1 deletions
--- a/Tapeti/Connection/TapetiClient.cs
+++ b/Tapeti/Connection/TapetiClient.cs
@ -656,7 +656,8 @@ namespace Tapeti.Connection
                Password = connectionParams.Password,
                AutomaticRecoveryEnabled = false,
                TopologyRecoveryEnabled = false,
-                RequestedHeartbeat = TimeSpan.FromSeconds(30)
+                RequestedHeartbeat = TimeSpan.FromSeconds(30),
+                DispatchConsumersAsync = true
            };

            if (connectionParams.ClientProperties != null)