Ensure consume runs asynchronously

ethanhann · ethanhann · commit 1f390165b5b9 · 2022-08-29T12:43:06.000-07:00
diff --git a/src/InEngine.Core/Queuing/Clients/RabbitMQClient.cs b/src/InEngine.Core/Queuing/Clients/RabbitMQClient.cs
@@ -139,6 +139,8 @@ public async Task Consume(CancellationToken cancellationToken)
             eventingConsumer.Model.BasicAck(result.DeliveryTag, false);
         };
         Channel.BasicConsume(queue: PendingQueueName, autoAck: false, consumer: consumer);
+
+        await Task.Yield();
     }
 
     public async Task<ICommandEnvelope> Consume()

Original file line number	Diff line number	Diff line change
`@@ -139,6 +139,8 @@ public async Task Consume(CancellationToken cancellationToken)`
`139`	`139`	`eventingConsumer.Model.BasicAck(result.DeliveryTag, false);`
`140`	`140`	`};`
`141`	`141`	`Channel.BasicConsume(queue: PendingQueueName, autoAck: false, consumer: consumer);`
	`142`	`+`
	`143`	`+ await Task.Yield();`
`142`	`144`	`}`
`143`	`145`
`144`	`146`	`public async Task<ICommandEnvelope> Consume()`