我正在为我的Rebus处理程序编写一些单元测试。我选择了启用secondLevelRetriesEnabled，这会导致在处理程序中抛出异常时发布IFailed<TMessage>。我的Handler类定义是： Handler<T> : IHandleMessages<T>, IHandleMessages<IFailed<T>
浏览 21提问于2021-10-14得票数 1
回答已采纳
即使在显式地设置了值5之后，我也观察到重试次数超过了5(最近达到了> 10 )。配置为SetNumberOfWorkers:5，SetMaxParallelism: 10，SimpleRetryStrategy(maxDeliveryAttempts: 5，secondLevelRetriesEnabled: true)，
在处理程序中，如果我们不能将消息作为最佳建议的实践来处理，我应该显式抛出异常，返回null，还是让异常传播(此时我捕获了异常日志并重新抛出)--这会影响行为吗？
浏览 8提问于2019-01-29得票数 1
我试图在rebus消息处理程序中发布来自catch块的消息，而不影响Rebus的重试机制。在消息处理程序中处理消息。在发生错误时，捕获它，并使用相同的总线发布一些错误事件。在发布“抛出”捕获的异常后，自动放置rebus ACK/NACK，以便重试/重发消息。。
我无法实现上述目标，因为如果从rebus消息处理<
浏览 2提问于2021-08-12得票数 0
回答已采纳
1回答
我正在考虑一种在Rebus中管理失败消息的方法。在我的第二级重试策略中，我希望将消息和异常详细信息保存到数据库中，以便稍后可以查看错误详细信息，并决定是将消息重新发送到要重新处理还是忽略并删除。在处理程序中，我捕获的细节如下： {
//Logicto Defer Me
浏览 0提问于2019-09-09得票数 2
1回答
使用Rebus中的第二级重试()，在n次重试之后，我需要向错误队列转发一条消息。这样做是可行的：但是对于如何实现这一点，有什么想法吗？
浏览 1提问于2017-05-03得票数 4
回答已采纳
我正在创建一个使用Rebus与Azure服务总线相关的概念的证明，但是我遇到了一个问题，即解析来自外部源的队列中的消息。我查看了GitHub，并注意到这个清单中有人是如何对RabbitMQ有类似问题的，建议使用装饰器：
var message = new BrokeredMessage("<xml>This is a test <em
浏览 7提问于2016-12-06得票数 1
1回答
考虑到我有一个web/SOAP服务，如何为Rebus (消息总线)设置和删除适当的事务上下文？当Rebus调用到消息处理程序时，这不是问题，因为Rebus将在调用处理程序之前设置事务上下文--但是web服务处理程序需要通过Rebus发送/发布消息的相反位置呢？我不感兴趣的是如何实现HTTP模块或类似的东西--仅仅是关于Rebus的基础知识:需要
浏览 3提问于2016-11-03得票数 1
回答已采纳
我们使用rebus和Sqs进行消息传递。我们还在每个队列上配置了一个重新驱动策略，在重试3次后将消息移动到DeadLetter队列。我们有许多处理程序来处理相同的消息类型：{ {
浏览 15提问于2017-02-03得票数 1
Rebus不支持DTC，根据这一点：，但是根据这个，Rebus确实使用TransactionScope。我猜这意味着轻量级事务总是不能跨越多台机器或连接。在我的例子中，我想要一个EventHandler，它首先向Firebird写一些东西，然后写到RavenDB。Firebird和RavenDB都能够参与分布式事务。但是它们在Rebus创建的TransactionScope中使用。或者我必须为Rebus做一个DTC实现才能工作。
作为另一种选择，我可能只需要按照Rebus</em
浏览 0提问于2015-05-26得票数 2
回答已采纳
Hellooo迷们，我们已经使用Rebus 0.84 aka 1.0很多年了，现在转向了4.0版本的&它在实现和性能方面似乎有了很大的改进，但是在实现处理程序的过程中遇到了一些问题。示例在以前的版本中，我们过去经常这样做。timeToBeReceived);
advancedbus.AttachHeader(message, Headers.Express, "rebus-express实现同样的方法，那么在
浏览 1提问于2019-05-13得票数 1
回答已采纳
1回答
我遇到了一些问题，因为我的处理程序没有“捕捉”我的事件。我目前的结构是，我在一个单独的包中对Rebus进行了包装，它包装了Rebus的方法，并公开了一个工厂，以便与Autofac一起使用--到目前为止还不错。当我发布一个事件时，比如MessageSent，我会在包装器中创建一个信封事件BusEvent，在其中我将域事件设置为一个Payload属性：
public Task Publish<T>( T payload不管怎样，我现在的问题是，
浏览 7提问于2017-02-13得票数 1
回答已采纳
1回答
在我的场景中，我已经在我的应用程序中实现了Rebus (使用azure servicebus) (将使用sagas创建一个PoC )。我订阅了该主题，将消息移动到我的队列中，并收到以下错误： Rebus.Exceptions.RebusApplicationException: Received message with emptyIf no ID is present, the message cannot be tracked between delivery at
浏览 26提问于2019-09-09得票数 0
回答已采纳
我确信，我对autofac IoC和Rebus缺乏了解会给我带来这个错误。System.InvalidOperationException未被处理[cut]
因此，当我在控制台应用
浏览 2提问于2014-07-21得票数 1
回答已采纳
我在测试我的指令时遇到了问题，该指令通过注册消息处理程序来启用跨文档消息传递： return{ angular.element($window).on('message', MyService.handleMessage);
浏览 4提问于2015-06-19得票数 1
回答已采纳
我们对新(异步)版本的Rebus有一个问题，而旧版本不存在这个问题。在程序集“Rebus，Version=1.0.0.0，C
浏览 1提问于2015-12-01得票数 2
回答已采纳
1回答
我试图在C#中使用C#作为Java的org.greenrobot.eventbus.EventBus的替代方案。无法计算如何动态注册处理程序的isntance。目标：using System.Threading.Tasks;
usi
浏览 5提问于2020-01-29得票数 2
回答已采纳
我有多个生成Message1的实例，每个实例都为特定的客户端运行，但是它们都生成消息类Message1的实例。这些消息需要发送到ASB。接下来，对于每个租户，我有很多竞争的消费者。换句话说，对于每个租户来说，有多个Message1使用者，但是只有一个使用者可以处理这个消息。这使我能够并行计算上的繁重工作。然而，Rebus会创建主题，因此启用多个订阅。据我所知，这意味着所有订阅者都将收到这些消息(因此导致重复)。当然，我们可以对这些消息进行过滤。但我没有找到任何明确的例子
浏览 0提问于2019-08-29得票数 4
回答已采纳
2回答
在我正在写入文件的channelRead handler适配器的ChannelRead中，我知道如何使用embeddedchannel来对netty处理程序进行单元测试，但是当我们在其中执行文件I/O(ChannelRead)时，如何对这个处理程序进行单元测试呢？) Logger.SentLo
浏览 38提问于2019-02-18得票数 0
1回答
我们有一个Rebus消息处理程序，它可以与第三方webservice对话。由于无法控制的原因，WCF服务经常抛出异常，因为它在自己的数据库中遇到了数据库死锁。然后，Rebus将尝试处理该消息五次，这在大多数情况下意味着这五次中的一次将是幸运的，不会出现死锁。但是经常发生这样的情况:消息在死锁后确实会陷入死锁，并最终出现在错误队列中。我已经做了一个Thread.Sleep(随机)来在某种程度上传播信息，但是在五次尝试之后，它仍然会放弃。我们在</
浏览 0提问于2013-05-30得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
