Потребитель RabbitMQ как Windows Рабочий - PullRequest
Новая
       33

Потребитель RabbitMQ как Windows Рабочий

0 голосов
/ 12 февраля 2020

Попытка создать службу containerised windows с использованием docker для приема сообщений из очередей rabbitmq. Я также использую EasyNetQ клиент для связи с RabbitMQ.

Однако происходит сбой при Persistent Исключение тайм-аута канала

Запрошена операция по тайм-ауту PersistentChannel

Здесь мой код для выполнения потребителя 

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
          try
          {
              using (var bus = RabbitHutch.CreateBus("host=localhost;username=guest;password=guest"))
              {
                 bus.Receive("Queue", msg => msg.Add<CustomModel>(m =>
                 {
                   _logger.LogInformation("Received Message: {0}, {1}", m.Prop1, m.Prop2);}));
                 }
                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);               
              }
           }
           catch (Exception ex)
           {
               _logger.LogError(ex.InnerException?.ToString());
           }
     }
}

Я не совсем уверен, что может быть причиной тайм-аута? У кого-нибудь есть похожая проблема?

...