Пример кода для использования Rebus с служебной шиной, очередью и темой Azure

Я новичок в Rebus, я ищу образец кода для использования Rebus с Azure Service Bus, Queue и Topic.

Я не вижу его по ссылке ниже: https://github.com/rebus-org/RebusSamples

Обновить

Для начала: пример постановки и удаления сообщений в служебную шину Azure для конфигурации очереди и темы.

В идеале, если возможно, охватите больше областей служебной шины Azure.


azureservicebus azure-servicebus-topics azure-servicebus-subscriptions azure-servicebus-queues rebus
person Pingpong    schedule 10.04.2019    source источник

Ответы (1)


arrow_upward
1
arrow_downward

если вы хотите использовать служебную шину Azure с Rebus, вы можете буквально начать работу с такой простой задачей, как

Configure.With(activator)
    .Transport(t => t.UseAzureServiceBus(connectionString, "my_queue"))
    .Start();

где activator - это либо BuiltinHandlerActivator Ребуса, либо контейнерный адаптер для вашего любимый контейнер IoC.

Вы можете посетить страницу вики о служебной шине Azure. транспорт - в нем показаны основы конфигурации, а также объясняется еще кое-что, например, о долгоиграющие обработчики сообщений.

person mookid8000    schedule 10.04.2019
comment
Я наткнулся на ссылку github.com/rebus-org/Rebus / wiki / Azure-Service-Bus-transport до того, как я разместил здесь вопрос. Я думал, что есть образцы по этой ссылке github.com/rebus-org/RebusSamples. Существуют ли образцы, которые не показывают служебную шину Azure, но могут использоваться для служебной шины Azure с некоторыми изменениями? - person Pingpong; 11.04.2019
comment
Практически все образцы можно изменить для использования служебной шины Azure, если вы замените все .Transport(t => t.Use...) на .Transport(t => t.UseAzureServiceBus(...)) - хотя вам потребуется удалить некоторые части, если они также настроены, например .Subscriptions(s => ..), потому что служебная шина Azure не поддерживает нужна эта конфигурация из-за встроенного pub / sub - person mookid8000; 11.04.2019
comment
Я также искал рабочий пример служебной шины Azure и попытался применить предложение @ mookid8000 и обновил пример приложения RabbitTopics для использования Azure ServiceBus. Когда я затем запускаю программу, я вижу следующую ошибку в консоли: Произошла ошибка при попытке получить следующее сообщение: System.InvalidOperationException: операция недопустима из-за текущего состояния объекта. - person Sipke Schoorstra; 22.11.2020
comment
Я создам проблему для этого с более подробной информацией. - person Sipke Schoorstra; 22.11.2020