有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
将Spring Insight与使用Spring Integration 1.0.4的应用程序结合使用
我正在尝试将现有应用程序部署到tc服务器。我在tomcat上使用此应用程序已有两年了,生产版本已在tc-server上运行。我已经安装了tc -...
我正在使用Spring Integration过滤器对传入的有效负载进行结构验证,如果验证失败,那么我想向原始消息中添加一些自定义标头。过滤器代码...
Spring Integration DSL过滤器与带有单个收件人和DefaultOutputToParentFlow的RouteToRecipients
当给定评估返回false时,我需要将消息从父流程路由到新流程,但当该评估返回true时,请在父流程中继续传递消息。目前我有...
您是否可以将@MessageGateway自动连线到RestController中
您可以检查here.吗?他们为该错误写了几乎所有错误的内容。就我而言,主类中缺少@EnableAutoConfiguration。另外,这可能是由于@ComponentScan。
是使用ThreadPoolExecutor应用程序范围的请求范围的ExecutorChannel的池大小
[当前,我将执行程序通道与执行程序一起用作拆分器的输出通道,该拆分器将一条消息拆分为2条不同的消息以并行运行。我已经设置了该输出通道...
丢弃Spring Integration DSL服务激活器中的消息
有没有一种方法可以从使用Spring Integration DSL .handle()方法定义的Spring Integration Service激活器中丢弃消息?更具体地说,假设...
无法将Message从Json String转换为Object。 ClassCastException
我正在使用SpringXD,其中我的Rabbit源具有outputType application / json。下一个模块将其接收并将其转换为Java Object。 RabbitMq是我的运输巴士。我的配置很漂亮...
当RabbitMQ交换不存在(并且消息通过消息传递网关接口发送时,如何处理错误]
我想知道在以下情况下处理错误的规范方法是什么(代码是一个最小的工作示例):消息通过定义其消息的消息传递网关发送...
我正在使用Spring Boot 2.2.4-RELEASE和Spring Integration 5.2.3,并且正在使用IntegrationFlow和DSL,因为我需要配置多个IMAP服务器。所以我写了这段代码:String flowId = ...
我已配置我的spring集成应用程序来管理这样的错误:
带有RotatingServerAdvice的Spring SFTP适配器InboundAdapter-获取完整路径
使用spring-integration-sftp:5.1.3我有一个RotatingServerAdvice入站设置,它正在监视两个目录:--inbox ----- dir1 ----- dir2监视:inbox / dir1和inbox / dir2 Local ...
不带参数的Spring Integration Gateway
在我的网关上,我有一个方法@Gateway String commsTest();我的想法是,我可以从bean调用commsTest并使用spring集成将其连接到服务激活器,该服务激活器将检查...
处理多线程拆分器/聚合器流程中的异常,使其转到聚合器而不是MessagingGatewaySupport的errorChannel
我目前有一个拆分器,可将一条消息拆分为类似的消息,其中我仅添加一个标头值,该值会在通过业务流程时导致不同的响应。最后,...
在Spring Integration中,我有一个DSL设置,看起来像这样:---> ---> ...
处理文件后通过SftpOutboundGateway删除文件
我正在使用Spring Integration从SFTP服务器读取文件,并且使用带有Java配置的InboundChannelAdapter可以正常工作。现在,我想修改我的过程以删除所有...
Spring Integration:聚合器将在超时时使消息过期
我正在使用SI的聚合器模式来保存事件并等待完成事件并将其存储在JdbcMessage存储中。我已经创建了表INT_MESSAGE,INT_MESSAGE_GROUP和...
当重新启动服务时,如何确保Spring Integration轮询器工作并执行错过的时间表?
IntegrationFlows .from(()-> new GenericMessage <>(“”),e-> e.poller(p-> p.cron(“ 0 0/5 * 1/1 * *”)))在在上述集成流程的情况下,存在cron ...
我正在尝试在一个项目中结合使用Spring Batch和Spring Integration。所以我的想法是,使用StepBuilderFactory的Spring Batch使用自定义方法读取文件,该方法返回一个String,而....