1 write to _messageChannel
OrderProcessor (1)
OrderProcessingWorker.cs (1)
33
_messageChannel
= await _messageConnection.CreateChannelAsync();
4 references to _messageChannel
OrderProcessor (4)
OrderProcessingWorker.cs (4)
34
await
_messageChannel
.QueueDeclareAsync(queueName, durable: true, exclusive: false);
36
var consumer = new AsyncEventingBasicConsumer(
_messageChannel
);
39
await
_messageChannel
.BasicConsumeAsync(
50
_messageChannel
?.Dispose();