spring-integration

1热度

1回答

我正在研究Spring应用程序，它将每分钟收到大约500个xml邮件。下面的xml配置只允许每分钟处理大约60条消息，其余的消息存储在队列中（保存在数据库中），并以每分钟60条消息的速度检索。尝试从多个来源阅读文档，但仍然不清楚Poller与任务执行程序结合的作用。我理解为什么当前每分钟处理60条消息是因为轮询器配置中的“固定延迟”值设置为10（因此它将在1分钟内轮询6次）以及“最大每轮询消息”

0热度

1回答

Spring集成TCP“空有效载荷从连接”警告

我通过注释配置了以下配置的简单TcpOutboundGateway： @Bean @ServiceActivator(inputChannel="toTcpChannel") public TcpOutboundGateway outboundClient() { TcpOutboundGateway tcpOutboundGateway = new TcpOutboundGatew

0热度

1回答

与更新的AWS凭证绑定的Spring集成

我正在使用spring-cloud-stream API和kinesis-binder到我的应用程序。我必须承担角色，因为〜/ .aws/credentials文件中的凭证不允许访问我希望连接的kinesis流的连接。我能够从〜/ .aws/credentials文件中获取证书，并调用STS承担角色并设置环境变量以使用更新的access-key-id，access-secret-key和toke

0热度

1回答

延时器连同Splitter，不连续处理的消息

我的要求是一个接一个地以串行方式处理（调用Webservice）消息列表。如果第一条消息成功，那么只处理第二条消息等。我在这里使用Splitter拆分消息。 Splitter内部我使用了Delayer（不是持久化）。问题是只要第一条消息进入延迟，列表中的第二条消息开始处理，而不等待第一条消息完成。我相信这是发生的，因为延时器不会阻塞线程。有没有办法通过使用Splitter和延迟器来实现这个

-1热度

1回答

如何获取标题值并将其传递给spring属性中的bean属性？

我正在寻找获取标题值以在Spring集成中将bean属性传递给它。我曾尝试以下步骤，但它不工作： <bean id="loggingInterceptorId" name="loggingInterceptor" class="LoggingInterceptor"> <property name="id" value="#{headers.get('id')}"></propert

0热度

1回答

服务激活器未被调用

我正在尝试这个用例：在队列中轮询消息 - >转换消息 - >使用转换后的消息调用方法。这里是我的代码 <jms:message-driven-channel-adapter id="jmsIn" destination-name="test" channel="jmsInChannel"/> <channel id="jmsInChannel"/>

1热度

1回答

是否可以仅使用java批注来配置弹簧集成'MessageHandlerChain'？

一个支持命名空间 xml配置允许处理程序链标签内处理程序的嵌套象下面这样： <int:chain input-channel="input"> <int-xml:marshalling-transformer marshaller="marshaller" result-type="StringResult" /> <int:service-activator ref="som

1热度

1回答

弹簧入站文件通道适配器prevent-duplicates = false不起作用

弹簧入站通道适配器出现问题。导入新文件的效果非常好。但是，选项prevent-duplicates =“false”似乎不能正常工作 - 当具有相同名称的文件保存到指定的目录时，它不会被导入。入站通道适配器的定义： <int-file:inbound-channel-adapter id="incidentExportAdapter" directory="file:${inciden

1热度

1回答

Spring集成Java DSL - 流中的可重用对象

我是Spring Integration DSL的新手，我遇到了一个问题。我需要在子流中的特定点或流中的任何其他点使用Object的流开始，就像在整个流中可重用的Session变量。以下是我转换udp请求的示例，将它转换为发送到api函数的http请求，并且接收到的响应不包含进行udp响应所需的数据。所以不知何故，我需要udp请求中的数据来制作udp响应。我一直在考虑拆分器，但我不认为这是一个解决

0热度

1回答

内容丰富者与服务激活者之间的区别是什么？

http://www.enterpriseintegrationpatterns.com/patterns/messaging/DataEnricher.html http://www.enterpriseintegrationpatterns.com/patterns/messaging/MessagingAdapter.html 如果有一个信道效应初探，服务激活似乎完全相同富集。