文件writestring的春季表达式可为AccessDeniedException提供
inbound: processed: path: C://inbound/processed/FedEx.txt @Bean(name = "inboundProcessedDirectory") public File inboundProcessedDirectory(@V…
Spring Integration SFTP:使用私人键
我有一些Hickups为Spring Integration SFTP设置了私钥。 以为我可以在这里分享我的发现。 我在其他地方读到,我应该用私钥对JSCH对象进行参数化。 但…
春季集成渠道首次起作用,然后不第二次
当使用春季集成和通道与另一集成流程时,它仅在第一次工作。 然后,它跳过频道并返回。 从第一个集成流程: .handle((p, h) -> { System.out.println(…
如何在春季集成中添加可配置的超时
我在项目中使用了Spring-Integration Java DSL,我想为所谓的并行服务添加可配置的超时。我应该能够为我在这里使用的不同流量添加不同的超时。请帮助…
等待executorChannel在Junit完成
我正在使用春季集成和Junit。 @Test public void testOnePojo() throws Exception { ExecutorChannel orderSendChannel = context.getBean("validatio…
启动应用程序中使用@serviceactivator在春季云流中
我将@serviceactivator录制为给Kafka错误的所有消息: @ServiceActivator(inputChannel = "errorChannel") public void handleErrors(final ErrorMess…
Spring Integration-指定' schema'在StordProcpollingChannelAdapter中
当使用 StordProcpollingChannelAdapter 时,如何设置模式?我确实在同一数据库连接对象上有2到3个模式,而传统的“ schema”。“ stored_proc”参考…
不读取所有邮件都在收件箱中使用多个MailID用于IntegrationFlows .from(邮件)
即使我将调度程序池大小配置为 5 ,有时它没有在收件箱中读取所有邮件。 @Bean public IntegrationFlow customerCareMailFlow() { return Integration…
将过滤器从XML迁移到纯Java配置
我正在尝试将一个项目从混合的XML/Java配置迁移到纯Java Config(尚未Java DSL,而是注释@BEAN方法)。 到目前为止,我设法转换了通道,入站通道适配…
如何为春季集成DSL配置类编写Junit 5测试用例
在这里,我使用的是散点图,并拨打了3个子流程。然后收集它们并汇总它们。我需要为配置类,网关和控制器编写JUNIT测试用例。我是春季整合的新手,所以…
如何使收集者仅接收一些特定的流程,而不是等待所有流量,然后在S集成中收集响应
在这里,我使用的是散点图,并拨打了3个子流程。其中一种流(DBFLOW)花了很多时间,因此Gatherer等待了这么长时间。我希望发生DB流量,但这是一项独…
使用Spring Integration DSL调用SOAP Web服务
我需要从我的休息服务中调用SOAP Web服务。我在项目中使用春季集成。目前,我正在使用基于XML的配置来实现目标。但是我想在Java DSL中编写代码。请帮…