1

Насколько я понимаю в текущей реализации библиотеки RabbitMQ.Client (https://www.nuget.org/packages/RabbitMQ.Client/) для c# нет асинхронного варианта для метода BasicPublish. Я хотел бы что бы вызов этого метода был асинхронный что бы не блокировать потоки.

Я написал вот обёртку но не уверен в том что сделал это правильно, подскажите кто знает:


Exception exception = null;
await Task.Run(() => { 
    try {
        _channel.BasicPublish("", basicProperties.ReplyTo, replyProps, content);
    } catch (Exception e) {
        exception = e;
    } 
});
if(exception != null) {
    throw exception;
}
2
  • Последняя реализация похожа на то что нужно, можно даже без фигурных скобок в одну строчку.
    – aepot
    11 июл 2020 в 16:53
  • 1
    Вы можете сами ответить на свой вопрос, а затем принять ответ, при этом рекомендуется удалить ответ из вопроса. Еще раз поясню, что то, к чему вы пришли - правильный способ сделать то что вам нужно.
    – aepot
    11 июл 2020 в 17:01

2 ответа 2

0

Немного полистав интернет пришёл к такой реализации:

return Task.Run(() => 
    _channel.BasicPublish("", basicProperties.ReplyTo, replyProps, content);
);
0

Все то же самое, но без await. Можно так же сначала создать поток, потом его запустить:

    Task task = new Task(() => { 
        try {
            _channel.BasicPublish("", basicProperties.ReplyTo, replyProps, content);
        } catch (Exception e) {
            exception = e;
        } 
    });

   task.Start();  

              

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.