rebus 相关问题

Rebus是.NET的精简服务总线实现,与NServiceBus,MassTransit类似,只是更精简。

在消息处理程序中如何立即停止处理新消息?

我有一个 Rebus 总线设置,其中有一个工作进程,最大并行度为 1,可以“顺序”处理消息。如果处理程序失败,或者出于特定的业务原因,我想要巴士

回答 1 投票 0

将 DbContext 创建到消息处理程序中

我有一个 dll,它公开了类似的类型 公共类 MyDbContext { [...] } 在这个库中,我还有一个 IPackage 实现,它在容器中注册 MyDbContext,例如 公共...

回答 1 投票 0

Rebus 中的“SetMaxParallelism”和“SetNumberOfWorkers”在多大程度上混淆了处理来自两个主题的消息的顺序?

我一直向两个主题发送大量编号消息: 对于 (var i=0; i<500; i++) { await bus.Publish(new TestEvent1 { Order = i }); } for (var i=0; i<500; i++) { await bus.Publ...

回答 1 投票 0

Rebus 8 - Rebus.Subscriptions.ISubscriptionStorage,但主注册已存在

我正在尝试从 Rebus 7 升级到 Rebus 8,但出现了以下异常: System.InvalidOperationException:尝试注册主要 -> Rebus.Subscriptions.ISubscriptionStorage,但是主要

回答 1 投票 0

如何在Topos上实现Saga?

Topos it .NET 事件处理库,类似于 Rebus。与 Rebus 不同的是,它不仅仅用于消息,还用于事件处理。 Rebus 开箱即用地支持 Sagas,包括

回答 1 投票 0

Rebus,发送消息到服务总线 Azure DLQ

有什么方法可以将消息发送到服务总线Azure中的DLQ吗? 我努力了 等待bus.Advanced.TransportMessage.Deadletter(errorDetails:“希望它能起作用”); 但没有成功。我...

回答 1 投票 0

发布的对象非共享时无法接收rebusrabbitMQ消息

当尝试解决我无法使用 Rebus 通过 RabbitMQ 接收消息的问题时,我尝试使用此示例:https://github.com/rebus-org/RebusSamples/tree/master/PubSubNative 并发现...

回答 1 投票 0

在与Entity Framework Core 3.0结合的TransactionScope中征集Rebus,而不需要两阶段提交。

我使用的是Entity Framework Core与PostgreSQL.Npgsql.EntityframeworkCore.PostgreSQL 3.1.4和EF Core 3.1.4。我想在我的DbContext中覆盖SaveChanges,以便在同一个数据库事务中提交EF的变化和用Rebus发送消息。在我的DbContext中,我想覆盖SaveChanges,在同一个数据库事务中,既提交EF变化,又用Rebus发送消息。

回答 1 投票 1

Rebus断路器实现?

最近我与Rebus进行了很多合作,到目前为止,一切都很棒。一个令人关注的领域是,当我们有成千上万的消息正在处理中,并且...

回答 1 投票 2

Rebus Saga单元测试SagaFixture事件处理程序未触发

我正在尝试对Rebus的传奇进行单元测试。一切都进行得很顺利,直到我尝试使用SagaFixture上的事件来跟踪某些动作是否发生。例如,我有...

回答 1 投票 0

使用SQS进行重传-失败的消息由2个使用者处理的次数比已配置的重试次数多

我在使用SQS传输的Rebus中有一条失败的消息。我有2个Rebus使用者,每个使用者都配置了5次重试,并且可以看到失败消息的处理次数是5次到10次。我以为...

回答 1 投票 1

Rebus SqlServerTransportOptions

如果尝试在Rebus中配置SQL Server传输,则会遇到一条警告,提示已不再使用连接字符串,并且您将被引导使用SqlServerTransportOptions。但是我...

回答 1 投票 0

RebusTransactionScope的使用

我需要澄清在Rebus中使用事务作用域的情况。在配置选项中,我有o.HandleMessagesInsideTransactionScope();现在是否需要使用scope = new ...

回答 1 投票 1

将Rebus与旧版系统集成

有时,我们需要将现有的旧系统与新的工作流和通过rebus等框架开发的微服务进行集成。很多时候使用语言和...

回答 1 投票 1

在最大中止失败后未触发移至Rebus错误队列

根据错误处理维基的默认Rebus配置,应将有害消息移至错误队列。在第三方组件导致...

回答 1 投票 1

使用Kafka在Rebus中手动提交

将Kafka用作通过此lib进行的传输,Rebus是否有办法控制消费者何时提交消息?我想使用Kafka的事件,做一些可能会......>

回答 1 投票 1

同一消息的多个订阅者重新连接Azure服务总线

我有两个完全相同的使用者Consumer 1,使用(var adapter = new BuiltinHandlerActivator()){adapter.Handle (async(bus,message)=> {...

回答 1 投票 1

在 .net 核心 Worker 服务(或控制台应用程序)中配置 Rebus

我看到使用 Startup.cs 在 ASP.NET Core 执行管道中添加 rebus 非常简洁。 我想知道是否有同样巧妙的方法可以为 Worker 服务或通常的控制台应用程序做同样的事情。

回答 2 投票 0

Rebus,将Castle Windsor与Rebus结合使用

我正在尝试将Rebus与Azure Service Bus和Castle Windsor一起使用。当我使用不带Castle Windsor的代码版本时,将正确创建队列和主题:public static void Main(string [] ...

回答 1 投票 0

Rebus主题的事件处理程序

我们知道Rebus除了提供熟悉的基于类型的路由之外,还提供基于主题的路由,尽管我们被告知基于类型的路由遵循相同的原理。但是在我这边...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.