Моя текущая реализация:
Код: Выделить всё
private async Task EnqueueAsync(ServiceBusMessage message, string queueOrTopicName)
{
var sender = _serviceBusClient.CreateSender(queueOrTopicName);
try
{
await sender.SendMessageAsync(message);
_logger.Info($"Message has been published to {queueOrTopicName}");
}
catch (ServiceBusException ex)
{
_logger.Error($"Error while publishing data to the Service bus: {ex}");
throw new QueueException("Unable to publish data.");
}
finally
{
await sender.DisposeAsync();
}
}
Подробнее здесь: https://stackoverflow.com/questions/781 ... bus-sender
Мобильная версия