在我的Spring Integration管道中，我得到一个XML有效负载，并且根据XML中属性的值，我必须生成一个密钥并将其发布到kafka。返回IntegrationFlows.from（...
目前，我有多个工作流程在同一应用程序中运行，但最终它们将在其专用的jvm中运行。看起来我只能使用一种处理方法使用一个服务激活器...
我正在编写一个通用适配器，该适配器从EMS获取消息并推送到Kafka主题中。如果配置文件中将特定标志设置为true，则必须丰富标题。 ...
使用Spring Integration从远程SFTP目录和子目录流式传输
我正在使用Spring Integration Streaming入站通道适配器，以从远程SFTP获取流并解析内容过程的每一行。我使用：IntegrationFlows.from（Sftp.inboundStreamingAdapter（...
Spring Integration File Support中的条件文件移动
我正在实现一个Spring Integration工作流程，如下所示。 IntegrationFlows.from（“ inputFileProcessorChannel”）.split（fileSplitterSpec，spec-> {}）...
我正在使用spring集成来处理文件。我想逐行读取文件，过滤，转换并发送到kafka。通过异步网关传递文件进行处理。在处理结束时，I'...
如何使用QueueChannel和ServiceActivator正确配置TCP inboundAdapter
我正在尝试配置一个TCP套接字，以不同的消息形式接收名称，值格式的数据。这些消息平均每秒发送一次，有时更快或更慢。我是...
[SimpleMessageListenerContainer-AMQP收到ClassNotFoundException警告消息
我刚刚将我的应用程序更新为spring-integration-amqp-5.2.4.RELEASE版本，当我从队列中收到消息时，一切正常，但是我注意到警告java.lang.ClassNotFoundException ...
带有JMS侦听器和任务执行器和断路器的Spring Integration Java DSL
我对Spring Integration Java DSL比较陌生。我想实现一个非常简单的场景，该场景当前由Spring Boot应用程序完成。从JMS队列中检索一条消息（即...
我正在使用Spring Boot 2.2.4-RELEASE和Spring集成。我正在开发一个简单的ImapReceiver。我需要以下内容：我可以配置多个Imap侦听器（我使用spring集成...
是在Spring集成中强制使用Java类型所需的任何其他属性
我们正在使用spring-integation（基于xml的配置），在其中执行以下步骤将有效负载（java-对象）转换为json进行其余api调用转换回java-对象
Spring集成（IntegrationFlowContext）：动态注册到同一WebSocket服务器的新路径
我正在尝试通过以下链接使用JavaDsl来实现Spring Websocket解决方案，即https://github.com/joshlong/techtips/tree/master/examples/spring-integration-4.1-websockets-example我...] >
Spring Integration DSL过滤器与带有单个收件人和DefaultOutputToParentFlow的RouteToRecipients
当给定评估返回false时，我需要将消息从父流程路由到新流程，但当该评估返回true时，请在父流程中继续传递消息。目前我有...
丢弃Spring Integration DSL服务激活器中的消息
有没有一种方法可以从使用Spring Integration DSL .handle（）方法定义的Spring Integration Service激活器中丢弃消息？更具体地说，假设...
我正在使用Spring Boot 2.2.4-RELEASE和Spring Integration 5.2.3，并且正在使用IntegrationFlow和DSL，因为我需要配置多个IMAP服务器。所以我写了这段代码：String flowId = ...
在Spring Integration中，我有一个DSL设置，看起来像这样：---> ---> ...
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，而....