有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
如何在Spring Integration入站网关中接受MultipartFile
我想使用入站网关接受文件。使用常规的Spring Boot非常简单@RequestMapping(method = RequestMethod.POST,path =“/ upload / {configurationUid}”,consumemes = {“multipart / form -...
Spring Integration Kafka ClassNotFoundException:KafkaHeaderMapper
在使用spring-integration-kafka库运行Spring Boot应用程序时,我收到以下错误:引起:java.lang.ClassNotFoundException:org.springframework.kafka.support ....
我现在正在编写基于https://github.com/spring-projects/spring-integration-samples/tree/master/basic/tcp-client-server的编码我想知道这个好的源代码示例的监控信息。为......
需要关于aws S3的Spring Integration示例的示例代码作为inBound和apache kafka作为出站[关闭]
在Spring Integration上需要示例,将aws s3作为入站,将apache kafka作为出站。我想从aws s3读取数据并需要解析它们并将其生成为apache kafka主题
如何使用Spring Integration File Support创建一个方法将文件从一个目录移动到另一个目录?
我是自学春天。我想创建一个方法,其参数将是源目录,目标目录和文件名。 boolean moveFile(String sourceDir,String targetDir,String ...
Spring Integration S3'beanName'不能为空
我正在尝试使用S3入站通道适配器从S3下载文件。这是我的配置:s3.xml:
Spring Integration 5.0 Reactor类型支持
从发行说明(https://spring.io/blog/2017/11/29/spring-integration-5-0-ga-available):Reactive Streams支持通过FluxMessageChannel,ReactiveStreamsConsumer和直接组织....
如何对Spring IntegrationFlow进行单元测试?
我一直在使用Spring Integration DSL来实现一些消息传递处理流程。我怎样才能对单个IntegrationFlow进行单元测试,任何人都可以为我提供如何进行单元测试的示例...
我正在学习如何使用Java Spring Framework并开始尝试Spring Integration。我正在尝试使用Spring Integration将我的应用程序连接到MQTT代理...
Spring Integration - SFTP入站适配器到S3存储桶而不是文件系统?
有没有办法连接SFTP入站通道适配器以使用S3备份存储而不是本地文件系统?
Spring Integration XML to Java HowTo - 具有不同参数的同一类的多个@ServiceActivator
在将Spring Batch和Spring Integration从xml转换为Java的过程中,我看到了一个用于多个@ServiceActivator的类,它具有不同的inputChannel和文件后的文件夹。看起来像这样:......
Dynamic-Sftp-Inbound-Adapter Spring集成
我正在尝试实现Dynamic Sftp入站适配器。以下是源文件和配置。问题是,它在线程挂起一段时间后有效,但是如果我运行Junit,即使...
我正在使用Spring 4.3.8和Spring集成4.3.9。我期望同时处理具有不同队列的多个文件。例如,有一些文件的文件名为A001,A002,A003,B001,...
Spring集成LoggingHandler将所有消息记录到Error
我创建了一个Spring Boot应用程序,它通过PublishSubscribeChannel发送消息。此频道作为SubscribableChannel接口“自动装配”。我只订阅了一个MessageHandler来......
如何根据spring集成中的一些验证将文件从一个目录移动到另一个目录?
Spring集成轮询目录中的文件,对其进行一些验证然后我想将其移动到另一个目录。如何实现相同? @Bean public IntegrationFlow ...
我使用spring集成来读取和处理来自ftp服务器的文件。为了使文件不被其他进程处理,应在处理之前重命名该文件。我怎么能用春天做到这一点......
Spring Integration - 处理陈旧的sftp会话
我已经实现了以下场景:一个queueChannel以byte []的形式保存Messages一个MessageHandler,轮询队列通道并通过sftp上传文件一个Transformer,听...
Spring Integration Rendezous通道确认速度慢
我有一个dsl流程,可以很好地使用Queue通道。但是,当我使用Rendezvous通道使其同步时,我获得最多30条消息/秒的确认率。我的处理程序只需......
寻找Spring Batch中远程分区的一个很好的参考示例。 Spring Samples项目仅用于本地分区。请分享任何好的指针。