gistfile1.cs

public async void Process()
{
     while(true)
     {
       var messages = bus.ReceiveBatch(1000,Timespan.FromSeconds(1));
       
       var tasks = new List<Task>();
       foreach(var message in messages)
       {
         //pass relevant message info to actor
         //complete the mq message if the actor is done
          var task = myConsistentHashRoutedActor.Ask<BusinessAck>(new SomeMessage(message.x,message.y), Timespan.FromSeconds(1)).ContinueWith(t => {
             message.Complete();
          });
          
          tasks.Add(task);
       }
       
       //wait for all tasks to complete before processing more messages
       //this could ofc be optimized to continue before all messages are done.
       await Task.WhenAll(tasks);
     }
}