有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
使用文件适配器我在固定利率从目录中读取文件,过滤某些文件的入站通道投票,最终对它们进行排序,并将它们发送到出站网关这...
美好的一天,我正在使用Spring集成2.2建立监听到一个文件夹。我想知道我怎么能检查将我的听众拿起文件时,文件传输一半?或者,它会等到...
处理多SFTP主机中的Spring Integration我想这样配置基于用户输入(用户通过主机名)多SFTP主机,我将选择主机并进行读操作。该...
setOnFailureExpression不工作的#root和#exception
后@Bean公共ExpressionEvaluatingRequestHandlerAdvice(){logger.debug( “评估表达意见。”); ExpressionEvaluatingRequestHandlerAdvice咨询=新...
我写了一些代码,相关的上传使用弹簧文件,它工作正常,现在我写的集成测试案例是,但我面临着一些问题,我的控制器的方法,@RequestMapping(...
让我们考虑以下上下文:2个Spring集成通道,它们各自处于单独的数据库事务中。在第一个事务结束时,将消息放入第二个通道。在......
简单的spring integraction xml config读取ftp文件列表并进一步拆分
我正在研究spring集成,并希望编写一个简单的应用程序,以便通过调度程序从ftp中检索文件列表,并将其拆分为几个通道进行并行处理。但无法理解如何运行......
Document Spring Integration http入站网关端点
作为我的开发活动的一部分,涉及使用Spring Integration创建REST API,我正在尝试探索记录API的可能性。在线阅读,我有几个......
如果我不想使用dsl编写构建jms和spring集成通道之间连接的代码,它是如何做的
在此链接中,作者使用java域特定语言来构建从spring集成通道到activeMQ的连接。如果我不想使用java dsl而我只想使用通用的java方法。 ...
TcpConnectionFactoryFactoryBean:使用SslContextSupport和SocketFactorySupport
我正在使用TcpConnectionFactoryFactoryBean(用于客户端,非NIO连接),并希望以两种方式修改我的SSL Socket连接:1 /仅使用TLS1.2协议我通过调用...
我想知道如何在对象的反序列化无法从kafka中删除记录时告诉kafka使用者,记录错误并继续侦听其他传入消息。我有我的消费者......
问题是,在spring集成中,入站适配器有preventDuplicates(true),这是如何工作的?问题的原因是,如果流程中断并且......
我们有一个JMS监听器,它从MQ中提取消息并将它们保存在数据库中。我的问题是什么是在db关闭时暂停JMS Listener临时的最佳方法,并在一些后再次恢复它...
无法删除Spring Integration Flow中的建议中的文件资源
我在文件中定义了3个流,用于轮询tif文件并将其发送到通道。该频道链接到另一个流,该流转换并复制到同一位置的pdf文件中。然后第三个流......
我想知道有没有办法使用SpEL来过滤掉像空集合这样的值。我的缓存当前过滤掉空值:@Cacheable(value =“groupIdToGroupNames”,除非=“#...
Spring Integration从基于时间戳的Kafka主题读取消息
使用spring kafka时,我可以使用以下代码 - ConsumerRecords从时间戳中读取主题中的消息 records = consumer.poll(100); ...
无法使用Spring REST Docs和springfox 3.0.0-SNAPSHOT生成Spring Boot + Spring集成的Swagger UI
我正在尝试使用Spring REST Docs样式和springfox 3.0.0-SNAPSHOT为Spring Boot + Spring集成项目(涉及入站网关)设置Swagger。按照说明......
我正在创建一系列使用Java DSL显式使用Spring Integration的进程。这些过程中的每一个都做不同的事情,但它们有一些相同的处理逻辑示例:get ...