如何为 MassTransit sagas 配置重试
我遇到了 MassTransit sagas 的并发问题。 我目前正在使用以下流程开发 POC: 一个线程生成 100 个事件,这些事件按顺序发布到 MassTransit。 当实例…
Masstransit UseInMemoryOutbox 无法与 MultiBus Saga 配合使用?
我实现了一个自定义活动来支持多总线传奇。 但我发现一个问题,即在状态传奇保存到 Redis 之前,我收到了来自 SecondBus 的已发布消息。 我认为 UseIn…
MassTransit 帮助注册多个传奇
我正在努力将一个旧应用程序移植到 .net6,并遇到了通过公共交通注册多个传奇的问题。 services.AddMassTransit(busCfg => { busCfg.AddSagaStateMach…
由 Bus.Publish() 或订阅引起的 StackOverflowException?
我有一个代理,它使用传奇来跟踪给定类型的传入消息,直到收到超时消息。在超时处理程序中,我有以下内容: public override void Timeout(object sta…
努力实施 IFindSagas
我有一个持续一天的传奇。 收到消息后,我想找到活动的传奇并在 Handle(message) 方法中执行操作。 我没有 ConfigureHowToFindSagas 方法,因为我想要…
在 NServiceBus 中,当消息传入而没有匹配的传奇时,我该如何处理?
如果我有一个由两种消息类型组成的传奇,比如由 message1 开始并由 message2 完成,那么如果 message2 进入而 message1 不存在,我可以返回回调吗?我…
如何解决与 NHibernateSagaPersister 的自动装配冲突?
我正在尝试连接我的第一个 Saga,但无法让接收端点正确处理启动消息。我得到以下异常: SagaMessageHandler 处理失败 信息。 Spring.Objects.Factory.…
使用 NService Bus 导入数据
使用 NService 总线。 2.00.19(使用 MSMQ 和 SQL 2008) 我们想要将数据导入到我们的系统中。 文件可能非常大,因此我们有后台处理器来从总线读取消…
当 Saga 有多个处理程序时,如何为 NServiceBus Saga 创建单元测试
我曾经做过这个测试,它通过得很好(一旦处理了所有三个消息,传奇就完成了。 Test.Saga(sagaId) .When(x => { x.Handle(new TestSagaStartMessageOne…
react项目, 在页面修改saga models文件的拿到的state, 为什么会直接更新了
models.jsexport default { namespace: 'myModel', state: { data: { list: [ { i: 1, disabled: false}, { i: 2, disabled: false}, { i: 3, disable…
redux saga 异步请求死循环,求帮忙看看
刚入坑,点击按钮抓取数据,陷入无限发请求,帮忙看看想要的效果是 打开请求之前打开loading,完成后关闭loadingconst TABLE_GET = "table_get";cons…
- 共 1 页
- 1