当前位置: 首页 > 知识库问答 >
问题:

在Spring xd中使用DLQ配置自动处理

左丘阳晖
2023-03-14

1)我想为我的流配置DLQ

 stream create --name httptest7 --definition "http |  http-client --url='''http://localhost:8080/mock-sentmessage/customers/send-email''' --httpMethod=GET | log" 
stream deploy httptest7 --properties module.*.consumer.autoBindDLQ=true

2)我已经做了

autoBindDLQ=true

我有一个疑问,如果假设Spring xd无法处理我的消息并将其发布到dlq。他们会自动将我移到我的原始队列重试吗?或者我应该编写一个处理器来将我的DLQ消息移到我的原始队列

3) 现在我放下我的Web服务http://localhost:8080/mock-sentmessage/customers/send email我可以在我的dlq中看到消息。

4)当我调出我的服务时。但是根据我的理解,我认为当我的服务启动时,DLQ会再次重试消息。

但是从DLQ不会再次重试。我需要设置任何配置吗?

根据文件:

没有提供自动机制将死字母消息移回总线队列。

共有2个答案

微生鸿轩
2023-03-14

正如您所知,您可以使用Rabbitmq中的Spoot插件来完成从DLQ到总线队列的移动。

李勇
2023-03-14

我不知道你的问题是什么,甚至你是否有问题;你似乎引用了留档来回答自己的问题:

没有提供自动机制将死字母消息移回总线队列。

所以,不;没有可以更改的“设置”。

您可以做几件事——编写自己的代码,将消息从DLQ移回主队列;使用Spring AMQP或您选择的任何语言只需要几行Java。

您还可以使用这里描述的技术,在DLQ上设置消息TTL,并将其配置为在TTL过期时路由回主队列。

 类似资料:
  • 我使用的是< code>SpringXD,我的配置如下: Spring集成kafka 2.1.0.释放 kafka客户端0.10.0.1 Kafka0.10.x.x Spring-xd-1.3.1.释放 我的 xml 文件中有以下配置: 这是我用来启动/停止频道的Java类: 然后我创建了一个基本流来检查我发送到主题的一些消息是否通过 我检查了创建的文件,它包含我发送到 Kafka 主题的所有消息

  • 基本上,我想问的是:将Spring Boot自动配置的bean自动导入XML配置文件的等价物是什么? 下面是我的主要Spring Boot入口点,它只是所有文档中列出的标准类: 我主要在一个Spring集成应用程序中使用它,在这个应用程序中Java配置还没有得到很好的支持,框架的核心是基于XML配置的,但是我希望在一些集成元素中使用Spring Boot自动配置的和bean。 https://gi

  • 这里是Java 8/Camel 2.19.x/AMQ 5.15.x。 我有一个Java应用程序,它使用Camel来使用AMQ队列中的消息,处理这些消息,并处理这些消息。有时路由的输出是将处理结果备份到另一个队列中,以供进一步的下游处理,但并不总是/必须。典型的Java/CAMEL/AMQ设置。 我的每条路由(我使用的是Camel XML DSL)都有一个配置的处理程序,通常如下所示: 非常简单:记

  • 问题内容: 我想 在Solaris上 配置Java代理设置以使用代理自动配置(PAC)脚本。 我已经找到了使用Java控制面板在Windows机器上进行设置的说明,但是在查找Solaris Java安装的位置/如何进行相同设置更改时遇到了麻烦。 我想使用代理自动配置(PAC)脚本,而不是手动为每个连接设置代理信息,或使用单个代理。我需要针对不同类型的URL利用多个代理。 问题答案: 可悲的是,系统

  • 问题内容: 是否可以在用Java编写的Spring配置中使用Spring的注释? 例如: 显然,不能直接实例化DataSource接口,但是为了简化起见,我在这里直接实例化了它。当前,当我尝试上述操作时,数据源对象仍然为null,并且Spring不会对其进行自动接线。 我通过返回一个Hibernate 对象成功地工作了。 所以我的问题特别是:是否有办法针对a ?或更笼统地说,在Spring Jav

  • 是否可以在Spring批处理中动态配置作业? 这是我想做的。我创建了几个不同的,如下所示: FlatFileItemReader 我希望能够在创建批处理作业时动态混合和匹配它们。例如,假设我需要一个有2个步骤的作业。第一步包含一个用于预处理的。第二步将有一个,用于使用我的阅读器/写入器进行基于块的数据处理......类似这样的东西: 在XML中,我可以执行以下操作: 但是我如何像上面一样以编程方式