-
0 votesanswersviews
Spring 天整合的背景下的并发消费者
在Spring集成应用程序中,我使用并发使用者一次使用和处理多个消息 . 在我的应用程序中,我将所有bean配置为单例 . 我假设我是否要通过使用并发消费者来并行化处理,将多个消息输入到相同的集成组件中 . 它会导致两个对象之间的数据冲突吗? -
0 votesanswersviews
Spring集成 - 来自sftp入站的聚合器
从包含多个文件的sftp入站消息源聚合一条消息的最佳解决方案是什么?我们有远程机器3需要接收的文件 . 之后,我们将这些文件的内容组合到一个json消息中并向前发送 . public IntegrationFlow sftpIntegrationFlowBean() { final Map<String, Object> headers = new HashMap<>... -
0 votesanswersviews
Spring Integration Java DSL SFTP异常处理
我正在使用spring Integration进行文件传输 以下代码工作正常,但如果我从源目录中删除文件夹它开始抛出异常 . IntegrationFlow flow = IntegrationFlows.from(Sftp.inboundAdapter(inboundSftp) .localDirectory(new File(classLoader.getResourc... -
1 votesanswersviews
spring-integration SimpleWebServiceInboundGateway
我正在使用SimpleWebServiceInboundGateway,目前我有网关将请求放入一个通道然后从通道消耗流量 . 一切似乎都很好 . 我的问题是,如果你有多个不同的soap endpoints 服务,每个服务的运行方式略有不同,我如何将这些 endpoints 映射到不同的流程,这样做的正确方法是什么?是否期望每个soap Web服务 endpoints 都有一个新的SimpleWeb... -
1 votesanswersviews
使用入站通道和响应通道动态生成TCP客户端
我是Spring集成的新手 . 使用Spring 4,只有java anotations . 我现在正在工作的项目我们在属性文件中设置了tcp连接 . 在momet它只硬编码到2个不同的连接,它必须改为更动态的方法,我们可以在属性文件中设置它们的可变数量,并能够在运行时添加新的连接 . 我知道dynamic tcp client example的存在,并试图将我的工作 Build 在它上面 . 首... -
0 votesanswersviews
在Spring Integration而不是ExecutorService中表示线程池
目前,我们的一个应用程序中存在类似于以下的代码: @Component public class ProcessRequestImpl { private ExecutorService executorService; public processRequest(...) { // code to pre-process request executor... -
1 votesanswersviews
Spring Integration窃听直接MessageChannel进行测试
我想对两个Spring Boot应用程序进行集成测试,这些应用程序也使用Spring Integration流程 . 要测试我的应用,我想检查通过 myMessageChannel 路由的消息 . 它在其中一个应用程序的XML流程中定义 . 如何连接到我的直接消息通道并将消息重定向到PollableChannel,以便我可以逐个读取它们?我在网上找到的所有方法都不适合我 . @RunWith(Sp... -
1 votesanswersviews
Spring Integration DSL变压器
我可以在下面的问题上获得一些帮助:调用转换器将输入对象转换为Map Object并调用处理程序,处理程序缺少之前添加的标头值 . 为什么要将有效负载转换为Map对象而丢失所有标头? //Adding header here setHeader("t", "t"); @ResponseBody public EmResponse getAud... -
2 votesanswersviews
Spring集成DSL:配置仅在参数匹配时处理的处理程序
我正在使用Spring Integration DSL配置 . 是否可以添加方法引用处理程序,以便仅在消息有效内容与处理程序参数类型匹配时才调用处理程序? 例如:在以下代码中,如果有效负载为 MyObject2 ,则Spring将在 handleMessage 处抛出ClassCastException . 相反,我想要做的是绕过 handleMessage 并被 handleMessage2 拾... -
1 votesanswersviews
Spring Integration DSL收集流之间的度量标准
我正在使用带有ActiveMQ的Spring Integration DSL和并发消费者,并尝试调整Spring IntegrationFlow的Metrics,它们使用直接通道和路由器相互交互 . 典型的Integration Flow如下所示: -> InboundFlow1 -> Transformer| ActiveMQ Broker ->JMS InboundAdapt... -
1 votesanswersviews
使用Spring Integration将文件复制到另一个引发异常的目录的基本示例
我是Spring Integration的初学者 . 我写了这个代码,它是在spring boot中引发异常“Bean named'messageSource'应该是'org.springframework.context.MessageSource'类型,但实际上是'org.springframework.integration.file.FileReadingMessageSource类型“”... -
0 votesanswersviews
在Spring Intgegration DSL中连接JDBC Store支持的两个队列通道
我正在尝试连接两个队列通道(由JDBC Store支持) . @Configuration public class DemoIntegration { @Bean public IntegrationFlow flow(MessageChannel firstJDBCChannel, MessageChannel s... -
2 votesanswersviews
如何为Spring Integration SFTP入站适配器动态定义文件过滤器模式?
我需要动态地将不同目录中的特定文件从不同的sftp服务器提取到spring引导应用程序的本地服务器目录 . 我将路径和文件模式存储在postgres数据库中 . 我得到了一切工作,但我不知道如何根据spring集成sftp入站适配器的远程目录动态定义文件过滤器模式,以便不会拉出该特定目录中的所有xml文件 . 我使用RotatingServerAdvice和DelegatingSessionFac... -
0 votesanswersviews
spring-integration:MessageProducer只能被引用一次
我想在多个流程中使用网关 . 我的网关定义是: @Bean @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) public MarshallingWebServiceOutboundGateway myServiceGateway() { Jaxb2Marshaller marshaller = new Jaxb2Marshaller(); ... -
2 votesanswersviews
Spring集成Java DSL - 动态创建IntegrationFlows
我正在使用Spring Boot 1.5.13.RELEASE和Spring Integration 4.3.16.RELEASE开发应用程序 . 我是Spring Integration的新手,我遇到了一个问题 . 所以基本的想法是,在一些外部触发器(可能是和HTTP调用)上,我需要创建一个IntegrationFlow,它将使用来自rabbitMQ队列的消息,与'em一起工作,然后(可能)生成... -
0 votesanswersviews
Spring集成Kotlin DSL MessageChannels.publishSubscribe
我正在尝试使用Kotlin与Java DSL进行Spring集成 . 从GitHub上的Spring Integration Java DSL参考https://github.com/spring-projects/spring-integration-java-dsl/wiki/spring-integration-java-dsl-reference#message-channels我得到了这...