NServiceBus稍后处理消息
我正在使用NSeriveBus构建一个系统，它应该只在特定的时间段将消息发送给远程处理程序。到目前为止，我设法将所有消息放在一个处理队列上，并从那里检查远程处理程序的可用性，如果处理程序不可用，我就不会通过边界发送消息。要做到这一点，我正在使用
Bus.HandleCurrentMessageLater()
但国家安全局会继续努力。这不像其他侦听器将在几分钟内启动并运行，但它可能有几个小时的停机窗口，因此这并不完全有效。
想知道是否有办法让总线稍后重试消息，或者不要继续重试，等待一段时间后再重试。我将使用Sagas，只是简单的命令/处理程序消息。
共有1个答案
你可以乘公共汽车。在版本3.0中，延迟在经过特定时间间隔后返回消息。
-
我正在使用Kafka Streams API (KTable，GlobalKTable..).我在用KStreams消费Kafka主题。我需要根据一些配置过滤出一些传入的Kafka事件，并在配置发生变化时处理它们。主题的持续时间限制至少为7天。以下是要求: 键值状态 K1 V1加工 K2 V2 未处理（基于某些业务逻辑） K3 V3 已处理 K4 V4加工 K1 V5加工 ------ 现在我想再
-
我有以下兔子听者： 我需要将listener配置为在它处理一条消息后等待15分钟，然后再接收下一条消息。不需要在此方法中等待。我所需要的只是在处理完一条后不接收任何消息。可以通过来完成，但我不确定这是否是实现这一点的最佳方法。对于这种情况有没有rabbitmq的配置？
-
在使用AsyncRabbitTemplate时，我在GZip/GUnzip消息处理方面遇到了问题。 使用同步模板设置时一切正常，如下所示： 但是，当我设置像这样的异步模板时： 回复消息没有正确解压缩，我得到了这个错误消息 我已尝试为AsyncRabbitTemplate提供一个配置好的DirectReplyToMessageListenerContainer，但没有帮助 这只会导致以下错误： [错
-
我正在使用来使用来自spring-boot应用程序中某个主题的消息，我需要定期运行该应用程序。spring-kafka版本是2.2.4.发行版。
-
前言 在消息处理后，会有内存回收的过程this.accumulator.deallocate(batch); 调用deallocate（）
-
我使用Java的rabbitmq-client(https://mvnrepository.com/artifact/com.rabbitmq/amqp-client)，我需要实现以下场景： 在接收Rabbit消息时，如果怀疑内存中不适合所有等待的数据，则可能需要暂停特定队列的Rabbitmq消耗。 处理完一些消息后，需要再次打开以下一组消息的消耗。 根据需要重复。 使用amqp-client J