Rebus是.NET的精简服务总线实现,与NServiceBus,MassTransit类似,只是更精简。
我有一个 Rebus 总线设置,其中有一个工作进程,最大并行度为 1,可以“顺序”处理消息。如果处理程序失败,或者出于特定的业务原因,我想要巴士
我有一个 dll,它公开了类似的类型 公共类 MyDbContext { [...] } 在这个库中,我还有一个 IPackage 实现,它在容器中注册 MyDbContext,例如 公共...
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...
Rebus 8 - Rebus.Subscriptions.ISubscriptionStorage,但主注册已存在
我正在尝试从 Rebus 7 升级到 Rebus 8,但出现了以下异常: System.InvalidOperationException:尝试注册主要 -> Rebus.Subscriptions.ISubscriptionStorage,但是主要
Topos it .NET 事件处理库,类似于 Rebus。与 Rebus 不同的是,它不仅仅用于消息,还用于事件处理。 Rebus 开箱即用地支持 Sagas,包括
有什么方法可以将消息发送到服务总线Azure中的DLQ吗? 我努力了 等待bus.Advanced.TransportMessage.Deadletter(errorDetails:“希望它能起作用”); 但没有成功。我...
当尝试解决我无法使用 Rebus 通过 RabbitMQ 接收消息的问题时,我尝试使用此示例:https://github.com/rebus-org/RebusSamples/tree/master/PubSubNative 并发现...
在与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发送消息。
最近我与Rebus进行了很多合作,到目前为止,一切都很棒。一个令人关注的领域是,当我们有成千上万的消息正在处理中,并且...
Rebus Saga单元测试SagaFixture事件处理程序未触发
我正在尝试对Rebus的传奇进行单元测试。一切都进行得很顺利,直到我尝试使用SagaFixture上的事件来跟踪某些动作是否发生。例如,我有...
使用SQS进行重传-失败的消息由2个使用者处理的次数比已配置的重试次数多
我在使用SQS传输的Rebus中有一条失败的消息。我有2个Rebus使用者,每个使用者都配置了5次重试,并且可以看到失败消息的处理次数是5次到10次。我以为...
Rebus SqlServerTransportOptions
如果尝试在Rebus中配置SQL Server传输,则会遇到一条警告,提示已不再使用连接字符串,并且您将被引导使用SqlServerTransportOptions。但是我...
我需要澄清在Rebus中使用事务作用域的情况。在配置选项中,我有o.HandleMessagesInsideTransactionScope();现在是否需要使用scope = new ...
根据错误处理维基的默认Rebus配置,应将有害消息移至错误队列。在第三方组件导致...
将Kafka用作通过此lib进行的传输,Rebus是否有办法控制消费者何时提交消息?我想使用Kafka的事件,做一些可能会......>
我有两个完全相同的使用者Consumer 1,使用(var adapter = new BuiltinHandlerActivator()){adapter.Handle (async(bus,message)=> {...
在 .net 核心 Worker 服务(或控制台应用程序)中配置 Rebus
我看到使用 Startup.cs 在 ASP.NET Core 执行管道中添加 rebus 非常简洁。 我想知道是否有同样巧妙的方法可以为 Worker 服务或通常的控制台应用程序做同样的事情。
Rebus,将Castle Windsor与Rebus结合使用
我正在尝试将Rebus与Azure Service Bus和Castle Windsor一起使用。当我使用不带Castle Windsor的代码版本时,将正确创建队列和主题:public static void Main(string [] ...