diff --git a/src/HouseofCat.RabbitMQ/Services/RabbitService.cs b/src/HouseofCat.RabbitMQ/Services/RabbitService.cs index 85dc306..c722721 100644 --- a/src/HouseofCat.RabbitMQ/Services/RabbitService.cs +++ b/src/HouseofCat.RabbitMQ/Services/RabbitService.cs @@ -44,6 +44,7 @@ public interface IRabbitService Task GetAsync(string queueName); IConsumer GetConsumer(string consumerName); + Task StartAsync(Func processReceiptAsync = null); ValueTask ShutdownAsync(bool immediately); }