Описание тега masstransit
MassTransit is a free, open source, lightweight service bus for the Microsoft .NET framework.
1
ответ
MassTransit, как справиться с падением RabbitMQ
Как правильно настроить MassTransit для обеспечения отказоустойчивости, чтобы справляться с периодически возникающими проблемами с подключением RabbitMQ или с полным отказом RabbitMQ? Я настроил кластер RabbitMQ между двумя разными машинами и настро…
30 ноя '16 в 19:17
2
ответа
Альтернативный метод для PublishRequest() в новом Masstransit
Я пытаюсь обновить мой код со старой версии Masstransit до более новой версии (v. 3) с помощью RabbitMQ, и я хочу использовать режим запроса / ответа, который мой старый код: public static void SendCommand<TCommand>(this IServiceBus bus, TComm…
29 сен '15 в 10:20
0
ответов
MassTransit Azure публикует много сообщений
Мне просто интересно, приходилось ли кому-либо отправлять / публиковать более 1 миллиона сообщений в Azure с помощью MassTransit. В настоящее время это очень медленный процесс отправки / публикации по одному сообщению за раз (10 минут для примерно 2…
13 фев '17 в 19:06
1
ответ
Как инвертировать / внедрить зависимость - MassTransit Consumer
Я работаю над проектом, и все работает, но у меня есть одна тесно связанная зависимость, которую я не понимаю, как инвертировать / ввести. Проблема в моем классе Consumer, который получит командное сообщение для запуска процесса, который является ча…
01 дек '17 в 00:34
1
ответ
MassTransit и события против публикации команд
Я новичок в MassTransit, и мне что-то не хватает в моем понимании. Допустим, у меня есть ферма серверов, где все узлы могут выполнять одну и ту же работу. Каркас приложения выполнен в стиле CQRS. Это означает, что у меня есть два основных вида сообщ…
27 июл '12 в 15:23
1
ответ
Как позвонить на сервисную шину Azure в Transactionscope
Когда я вызываю MassTransit.Publish на служебной шине Azure, у меня возникает исключение, потому что вызов находится в TransactionScope. The feature 'Transaction' is not supported with the current configuration Как отправить сообщение на шину без ре…
23 май '17 в 07:53
1
ответ
Отслеживание сообщений в общественном транспорте
Я использую masstransit в качестве сервисной шины и использую шаблон pub/sub для своего приложения. Я хотел бы выяснить, могу ли я отследить сообщение, которое приходит от автобуса подписчикам. Я использую json сериализатор. Есть ли у МТ некоторая "…
14 июл '12 в 03:43
1
ответ
Загрузка потребителей MassTransit из сборки
При загрузке потребителей MT из сборки (используя StructureMap контейнер / MassTransit.StructureMap сообщения интеграции пакета) обрабатываются частично: шина обрабатывает сообщения, хранящиеся в очереди, и не отвечает после этого, хотя вы можете ви…
27 май '15 в 12:39
2
ответа
Наследование сообщений и получение доступа к сообщению от потребителя
Прежде всего, я знаю, что наследование не совсем хорошо, и мы должны быть осторожны с этим, но... В системе у меня есть набор различных команд, которые я публикую на шину для запуска соответствующих служб. Теперь я хочу зарегистрировать тот факт, чт…
03 апр '18 в 14:09
1
ответ
Почему наследование является плохой практикой в дизайне контрактов сообщений
По мнению создателей MassTransit, наследование на основе классов не считается хорошей практикой - https://masstransittemp.readthedocs.io/en/latest/overview/inheritance.html Я честно не могу понять почему. Вот мой упрощенный сценарий из реальной жизн…
23 фев '19 в 13:05
2
ответа
Обработка перехода в состояние для нескольких событий
У меня есть MassTransitStateMachine, который организует процесс, который включает в себя создание нескольких событий. После того, как все события завершены, я хочу, чтобы состояние перешло в фазу "очистки". Вот соответствующая декларация состояния и…
18 апр '16 в 00:32
1
ответ
Как мы можем ускорить получение сообщений от MSMQ?
Узким местом моего приложения стала отправка и получение сообщений через MSMQ с помощью MassTransit. Отправка и получение происходят в одном приложении, но часто слишком много сообщений, чтобы использовать очередь в памяти. Вот моя простая настройка…
18 дек '13 в 16:16
1
ответ
Несколько сообщений одного типа в служебной шине Azure
Я пытаюсь понять функциональность Azure Service Bus. У меня есть приложение, развернутое в разных средах (dev, test, staging и т. Д.). Из того, что я видел, вы можете иметь только один тип сообщения на шину? Значит ли это, что для поддержки каждой с…
21 ноя '17 в 12:22
1
ответ
Условный переход в МассТранзит Автоматомная сага
У меня есть какое-то состояние в саге, и я пытаюсь выполнить попытки проверки состояния, пока не получу какое-то удовлетворительное значение в полученном мной сообщении. Скажем, у меня есть что-то вроде этого: .During(Pending, When(StatusChecked) .T…
23 мар '16 в 09:24
1
ответ
Как загрузить в контейнер MassTransit EndPoint в AbstractFacility
У меня есть класс PersistenceFacility. Этот класс унаследовал "AbstractFacility" как "Castle.MicroKernel.Facilities". Интересно загрузить и установить в контейнер: IWindsorContainer. public class PersistenceFacility: AbstractFacility { protected ove…
14 фев '19 в 12:21
0
ответов
Отсутствует IInMemoryBusFactoryConfigurator.SetHost() (или эквивалентный) в MassTransit v5
После успешного использования транспортов Azure Service Bus и RabbitMQ мы теперь рассматриваем использование транспорта InMemory для целей тестирования. Наше текущее решение потребовало бы, чтобы несколько экземпляров шины взаимодействовали друг с д…
14 янв '19 в 08:42
2
ответа
Как динамически установить количество предварительных выборок RabbitMq
Можно ли динамически задавать параметр количества предварительных выборок? Вот то, чего я хотел достичь. У меня есть служба, которая является абонентом очереди. У меня есть механизм, который наблюдает за ресурсами сервиса, такими как использование п…
16 сен '17 в 17:10
2
ответа
EntityFramework Saga persistance воссоздает схему в существующей БД
Я использую MT v3.0.17 с Automatonymous, я заметил, что таблица состояния экземпляра не создается, если база данных уже существует. Поскольку я направляю несколько разных автоматных конечных автоматов в одну и ту же базу данных, я бы хотел дать ей у…
30 дек '15 в 08:42
1
ответ
Масстранзит Saga redelivery
Я хотел бы настроить повторное получение расписания сообщений для саги о состоянии машины с использованием автономного кварцевого планировщика. Теперь он работает нормально с обычным потребителем, но я не могу правильно настроить повторную доставку …
25 янв '18 в 07:00
1
ответ
Как добавить пользовательские данные в ConsumeContext?
Я пытаюсь добавить пользовательскую полезную нагрузку в ConsumeContext, как это public Task Consume(ConsumeContext<Message1> context) { context.GetOrAddPayload(() => new Payload()); return context.Publish(new Message2()); } И ожидайте получ…
07 окт '16 в 08:29