有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
如何在Spring Integration应用程序中实现SmartLifecycleRoleController
我在int-ip:tcp端点的基础上编写客户端 - 服务器应用程序。代码写在Kotlin。应用程序包含两个tcp clienst,它应该按顺序连接到服务器,一个...
Spring入站通道适配器 - 如何自动删除超过10天的文件夹和文件
Integration.xml - 这将获取目录中的所有文件
Spring Integration基于文件名的Flow路径
我需要解压缩并存档和处理其内容。在zip文件中,可能有两种类型的文件个人或公司。这可以通过文件名来区分。处理完......
在spring-boot-integration应用程序中,编写了一个自定义锁定器,用于在锁定之前重命名原始文件(fileToLock.getAbsolutePath()+“。lock”)并预期锁定文件,以便任何其他实例不会...
我试图在Spring集成中创建Rest API,如@ResponseBody @RequestMapping(value =“/ employee”,method = RequestMethod.GET,RequestMethod.POST},produce =“application / json”)public ...
读取TCP回复消息时的MessageTimeoutException
我正在使用Spring集成为TCP遗留服务编写RabbitMQ接口。我能够连接到旧服务并发送XML字符串消息。旧版服务器回复...
我在队列中获取字符串消息。我正在使用它并使用以下通道processMessage进行进一步处理。现在我有一个要求,我需要将此消息发送到...
Spring:如何使用注释配置Messaging Bridge轮询器
我希望能够限制从SubscribableChannel收到的请求。我不使用PollableChannel。我是否能够做到这一点:
我有这样的Integration流:@Bean public IntegrationFlow inboundRequestFlow(){return IntegrationFlows.from(inboundRequestGateway())。log(...)。filter(...
Spring Integration错误“没有输出通道或replyChannel标头可用”
我不知道为什么我得到异常引起的:org.springframework.messaging.core.DestinationResolutionException:没有输出通道或replyChannel标头可用它只是一个简单的...
我需要根据消息内容从S3下载文件。换句话说,要下载的文件以前是未知的,我将在运行时搜索并找到它。 S3StreamingMessageSource ......
在Spring REST Docs测试中模拟@MessagingGateway
我有一个使用@MessagingGateway的@RestController,我想知道Spring REST Docs是否内置了用于模拟Spring Integration组件的支持。哪个最好 ...
Spring Integration的DefaultMessageListenerContainer和JPA中的事务
假设我有简单的IntegrationFlow,它以异步方式读取JMS消息,转换,应用业务逻辑等。@Bean public IntegrationFlow upstreamEventFlow(){return ...
SFTP Spring集成问题2 *用户名*的身份验证失败太多
我们有一个SFTP服务器,我们在这个服务器上读取文件特定文件夹。我使用基于用户/密码的身份验证我还需要提供一些其他属性...
@MessagingGateway,Spring Cloud Stream以及两者之间的错误处理
关于如何使用Spring Cloud Stream MessageChannels配置@MessagingGateway的答案?在@MessagingGateway处理错误的正确方法是什么?
Spring Integration - Java DSL中的AMQP推断类型?
我一直致力于使用AMQP在两个微服务之间建立异步消息传递的“铺平道路”。我们希望为每个服务推广使用单独的域对象,这意味着......
单元测试在测试spring集成TCP组件时创建名为“amqAdmin”的bean时出错
我正在编写一个边线微服务,它将TCP与传统应用程序进行对话,并在另一方面使用rabbitMQ。我刚刚开始编写测试,因为我一直在更好地理解一切......
我正在使用带有远程分块的spring批处理,并且我遇到以下问题:当主要使用json格式(application / json)在请求队列中发布事件时,我在奴隶时有一个例外...
我正在使用spring批量远程分块,我有以下问题:在主控方面,我在'ExecutionContext / jobExecution'中放入了一些信息,让它们回到...处理器中...