我想用spring boot在apache camel 3.3.0中开发soap web服务（生产者和消费者）（java DSL）。有哪些好的资源可以阅读和学习？
有什么方法可以通过spring集成获得流的状态（也许像，运行，停止，停止与异常）？
最近，我试图建立一个休息服务来创建、启动和停止一个集成流（它是读取一个RSS feed并在控制台打印），我能够实现这一点。但是我的下一个...
IntegrationFlowDefinition.aggregation不起作用。也许CorrelationStrategy失效了？
错误信息。原因是： java.lang.IllegalStateException: Null correlation not allowed. 也许是CorrelationStrategy失败了？我的实现，@Bean public IntegrationFlow start() { ...
Spring Integration DSL的EnrichedHeaders没有被替换。
使用 Boot 2.2.6 和 SI 5.2.5，我试图用一个对象来丰富报头。然而，在流程的第二次传递中，新的报头确实包含了一个新的消息 UUID（所以我知道这是一个新的报头），...。
我最近有一个类似下面的场景。 Flow_B应传递messageA+messageB......。
使用Spring Integration的Java邮件监听器：多个应用程序实例无法接收邮件。
我在一个Springboot应用程序中使用了以下代码。@Bean public IntegrationFlow mailListener() { return IntegrationFlows.from(Mail.imapInboundAdapter(receiver()), e -> e.poller(Pollers......)。
假设我的应用程序有以下2个流。@Bean IntegrationFlow flow1() { return IntegrationFlows.from(()-> LocalDateTime.now(), c -> c.poller(Pollers.fixedDelay(...)。
我正在使用Spring集成与DSL，我需要为不同的通道路由消息。简单地说，如果失败，它们应该进入一个输出通道，如果成功，它们应该进入其中一个 ...
没有发布者可发布 TcpConnectionOpenEvent TcpConnectionCloseEvent
我用Spring Integration的Java DSL配置了一个TCP Client。它看起来像这样 @Bean public TcpSendingMessageHandler tcpClient() { return Tcp .outboundAdapter(......)。
Spring IntegrationFlow用于多租户应用程序或要监视的多个文件夹
是否可以注册IntegrationFlow以进行多租户。假设要求为少数租户（例如INFY，TCS，WIPRO等）处理PF。每个租户都有自己的目录路径，并且具有相同的...
我已在程序中成功使用RecipientListRouter，根据该值我将其发送到多个通道。我想知道-1.这样可以保持执行顺序，在...
我正在尝试构建入站通道适配器以侦听位于外部JMS系统中的JMS主题。我发现的所有示例都是使用XML而不是使用Spring DSL完成的。你们有没有做过...
如何使用带有DSL配置的Spring Integration邮件在邮件中添加附件
我是Spring集成的新手，尝试使用带有DSL配置的spring集成邮件依赖项发送带有附件的电子邮件（Excel工作表）。我的问题是我不知道如何添加...
我有以下Spring Integration JAva DSL代码：返回流-> flow.channel（INPUT_CHANNEL）.transform（customMapper，“ mapFrom”）.enrichHeaders（...
我有一个消息生成器，它每秒产生约15条消息。消费者是一个Spring集成项目，它从Message Queue中进行消耗并进行大量处理。我用过...
我需要根据消息中的属性值将消息发送到特定的服务激活器。因此，当我收到消息时，将执行以下转换返回...
我正在尝试使用Spring Integration构建一个简单的API。对于API中引发的任何异常或错误，我想向客户端提供自定义错误响应。我正在尝试使用流结构...
Spring Integration DSL：基于消息有效载荷将消息发送到多个订户（不是所有订户）
我必须创建一个管道来向多个订阅者发送消息，我可以使用publishSubscribeChannel实现这一点。但是对于我来说，当我收到消息时-我有一个eventSubType，例如
Spring Integration：仅在处理完最后一次轮询的所有结果后才开始JPA轮询
我想使用Spring Integration Java DSL来实现以下流程：每2小时在数据库中轮询一个表，该表返回需要处理的文档ID。对于每个ID，...
在我的Spring Integration管道中，我得到一个XML有效负载，并且根据XML中属性的值，我必须生成一个密钥并将其发布到kafka。返回IntegrationFlows.from（...