Можно ли использовать async / await для публикации сообщения в RabbitMQ? - PullRequest
Новая
       9

Можно ли использовать async / await для публикации сообщения в RabbitMQ?

0 голосов
/ 23 ноября 2018

Я не могу найти никакой информации о том, как async'ly Опубликовать сообщение в RabbitMQ.

Примеры Я наткнулся на обычно оиспользование async / await для извлечения / получения сообщения из RabbitMQ. 

var consumer = new AsyncEventingBasicConsumer(model);

consumer.Received += async (o, a) =>
{
    Console.WriteLine("Message Get" + a.DeliveryTag);
    await Task.Yield();
};

Есть несколько примеров или примеров кода для этого?

Редактировать

Вот пример кода, с которым я пытался играть: 

public Task AddMessageAsync(string content,
                            TimeSpan? timeToLive,
                            TimeSpan? initialVisibilityDelay,
                            CancellationToken cancellationToken)
{
    _logger.LogDebug("Starting to add a Message to queue. {content}", content);

    CheckRabbitMQPolicy(_logger).Execute(() =>
    {
        using (var connection = _factory.CreateConnection())
        {
            _logger.LogDebug("Created a connection to factory.");

            using (var channel = connection.CreateModel())
            {
                _logger.LogDebug("Created a channel");

                AddMessageToRabbitMQPolicy(_logger).Execute(() =>
                {
                    _logger.LogDebug("Check or Create a queue '{queueName}'", _queueName);
                    channel.QueueDeclare(queue: _queueName,
                                            durable: false, // Could be TRUE
                                            exclusive: false,
                                            autoDelete: false,
                                            arguments: null);
                    _logger.LogDebug("'{queueName}' exists or was created.", _queueName);

                    var body = Encoding.UTF8.GetBytes(content);

                    _logger.LogDebug("About to publish message to queue '{queueName}'", _queueName);

                    //var foo = new AsyncEventingBasicPublish()
                    channel.BasicPublish(exchange: "",
                                            routingKey: _queueName,
                                            basicProperties: null,
                                            body: body);
                    _logger.LogDebug("Message published to queue '{queueName}'", _queueName);
                });
            }
        }
    });

    return Task.CompletedTask;
}

1 Ответ

0 голосов
/ 23 ноября 2018

В текущем состоянии клиент RabbitMQ .NET поддерживает только асинхронное потребление.

Если вы хотите выполнять только контракт, вы можете вернуть Task.CompletedTask, как и вы.

Если вы хотите начать какую-то работу и понаблюдать за ней позже, вы можете обернуть этот код вызовом Task.Run или просто поставить await Task.Yield() там, где вы хотите перейти от синхронного к асинхронному.

...