1回答
我正在使用Spring Integration filter对传入的有效负载进行结构化验证，如果验证失败，那么我希望向原始消息添加一些自定义的头。HTTP_STATUS", "400").build();
}
return status;但是报头不会填充到消息中看不到下一个组件中添加的标题。我到底做错了什么。
浏览 24提问于2020-02-16得票数 0
回答已采纳
2回答
我计划使用Spring Kafka客户端在Spring Boot应用程序中使用kafka设置并生成消息。我在Kafka 0.11中看到了对自定义头部的支持，作为详细的。虽然它对原生Kafka生产者和消费者是可用的，但我不认为Spring Kafka支持添加/读取自定义头部。我正在尝试基于重试计数为消息实现DLQ，我希望将重试计数存储在<
浏览 1提问于2018-02-15得票数 5
回答已采纳
1回答
我试图在spring集成消息中设置jms相关性id，方法是在进入IBM之前设置其头部，但是在从队列中读取消息后，该值不可用。
浏览 4提问于2021-12-10得票数 0
我想知道在中是否有任何方法向JMS文本消息添加属性。编辑
我试图添加Spring文档中给出的标题，但是现在我为每个消息获得相同的消息ID，但由于我打算将它用作Id，所以我需要对每个消息都使用
浏览 2提问于2015-09-14得票数 1
回答已采纳
1回答
我使用来自Edgware发行版的Spring 绑定器发送卡夫卡消息。我还使用了Spring 和Zipkin。我的问题是:是否有一种为消息头(例如普通JSON)配置自定义编码器/解码器的Spring的方法？或
浏览 3提问于2018-01-09得票数 1
回答已采纳
我们正在使用集成框架提供的wire-tap进行日志记录，并且我们已经设计了许多使用wire-tap进行日志记录的接口。我们目前使用的是spring boot 2.1和spring集成。
浏览 54提问于2019-04-23得票数 0
我见过的Spring Integration DSL Scatter-Gatherer的所有示例都显式地在散射器上设置了.applySequence(true)。
浏览 60提问于2021-07-16得票数 0
回答已采纳
我的问题是如何在MessageHeaders org.springframework.messaging.MessageHeaders中填充值并将其传递给激活器。
浏览 8提问于2015-03-18得票数 1
回答已采纳
我正在尝试在spring集成中实现一个自定义的入站通道适配器，以使用来自的消息。基于spring集成示例，我发现我需要创建一个实现MessageSource接口的类，并实现从kafka返回消费消息的receive()方法。但是基于，KafkaStream中的消息迭代器是由BlockingQueue支持的。因此，如果队列中没有消息，线程将被阻塞。在
浏览 1提问于2013-02-01得票数 0
回答已采纳
1回答
基于spring集成的转换器使用来自一个系统的消息，检查、转换并将其发送到另一个系统。 如果目标系统宕机，我们将停止入站适配器，但也希望在本地持久存储或转发当前“正在传输”的已转换消息。因此，只需将消息从正常输出通道动态重路由到某个“备份”-channel即可。在docs中，我发现只有一个选项可以根据消息的头部来路由消息(所以在流中之前的某个步骤中</em
浏览 14提问于2019-03-15得票数 0
回答已采纳
我们使用Spring-Boot和Apache camel连接到IBM MQ。我们需要在MQMessages中设置expire，这样如果我们没有得到任何响应，消息应该会在60秒内过期。我们添加了如下头部： setHeader(WMQConstants.WMQ_EXPIRY，常量(600))； 但添加的头部如下： <usr>
<breadcrumbId>ID-ff9c1ce374f9-1544430870241-0-2</breadc
浏览 59提问于2018-12-17得票数 0
我刚刚意识到，在Kafka主题上收到的消息丢失了标题。有没有办法在发布到Kafka Topic之前给消息添加头部，然后在消费者端阅读？我使用的是Java11，Spring Cloud Hoxton.SR6，Spring2.2.4，kafka_2.13-2.6.0。提前感谢！
浏览 0提问于2020-09-08得票数 0
1回答
我需要访问其请求结构如下所示的SOAP服务<?xml version="1.0"?GetStockPriceResponse></m:GetStockPriceResponse>
但是如何在出站网关中形成头部和
浏览 0提问于2017-06-20得票数 0
我有一条jms消息，报头中有一个名为id的属性。在我的监听器中，当此jms消息被转换为消息时我可以通过使用javax.jms.Message更改侦听器接收的
浏览 0提问于2021-03-18得票数 0
我们的javascript websocket客户端向所有STOMP消息添加“自定义”头。
我的项目使用spring @Controller处理websocket端点。)传递给一个spring集成@MessagingGateway。底层IntegrationFlow试图通过使用SPLExpression headers['custom']访问消息头来访问“自定义”标头。不幸的是，headers['custom']
浏览 3提问于2015-07-28得票数 3
回答已采纳
有没有办法在spring集成xml中从spring集成标头设置SOAP-ENV标头？</SOAP-ENV:Body>在调用出站网关之前，我还研究了下面的inside chain方法。看起来这个头丰富器只接受soap动作作为头。但我不能在链中编译它。
浏览 1提问于2016-09-09得票数 1
回答已采纳
我在一个Spring Boot项目(2.2.6版)中使用了Spring Cloud Gateway和Spring Security。我有一个自定义的预过滤器，它需要在将请求转发到下游服务之前向请求添加标头。预过滤器需要读取Spring Security的Authentication对象来获取权限，然后才能添加头部(它需要根据权限进行一些查找)。参考这个堆栈溢出问题，我在我的自定义预过滤器中<
浏览 6提问于2020-05-10得票数 1
我有一个Spring集成应用程序，它轮询一个目录中的输入文件，并将所有这些文件写入一个公共文件。这可以很好地工作。现在，我必须在输出文件中添加一个标题记录和一个结尾记录。我尝试查看SI，但使用Spring Integration无法在输出文件的开头和结尾插入头部和尾部记录。
SI是否提供任何开箱即用的功能？如果有人已经实现了类似场景。。。。请帮帮我！
浏览 0提问于2016-05-13得票数 1
我当前使用的是spring.kafka.version 1.1.6我发现你可以将kafka元数据设置为头部
浏览 12提问于2018-02-23得票数 0
1回答
调试部署到Spring运行时的自定义模块(版本1.3.1- runtime )并不容易。
log
浏览 1提问于2016-02-26得票数 0
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
