spring-integration

2热度

1回答

我有一个http网关调用，偶尔会返回503错误。我想在该呼叫周围配置retry advice，但我不想为每个错误都做这个，只是503s。 <int-http:outbound-gateway ... errorHandler="..."> <int-http:request-handler-advice-chain> <int:retry-advice max-attempt

0热度

1回答

SFTP持久性接受只在sftp网关过滤一次

我有这个代码中我想合并一个SftpPersistentAcceptOnceFileListFilter，我不知道如何。过滤器应在本地检索文件之前进行。 @InboundChannelAdapter(value = "sftpMgetInputChannel", poller = @Poller(fixedDelay = "5000")) public String filesForMG

1热度

1回答

Spring集成DSL：与FileSplitter开始/结束标记有效载荷处理

我想设置这样的集成信息流： return IntegrationFlows .from("inputChannel") .split(fileSplitter) .handle(this::doStuff1) .handle(this::doStuff2) .handle(this::doStuff3) .aggr

2热度

1回答

缩放Spring集成Web应用

有此无状态REST应用/ API通过我使用Spring集成API编写和正在维持与工作手在手以下基本概念： 1）入站HTTP网关为RESTful入口点 2）几个服务激活器，路由器，通道和变换器 3）一个分割器（和一个聚合器）与前者订阅了一个通道，该通道又有一个任务执行器接线，包括一个大小为线程池100用于并行执行拆分（特德）消息该应用程序目前无缝运行 - 作为下一个步骤中，我的尝试是扩展此应用程序

1热度

1回答

弹簧集成中的Windows密钥验证

我有一台Windows服务器，我需要将文件传输到另一台服务器，其中sftp。目标服务器可能是Linux或Windows系统。我的问题是，我必须依赖我的Windows机器上的第三方sftp服务器软件还是春天集成照顾呢？我应该如何在Windows上生成公钥和私钥对？

1热度

1回答

与观察服务和LastModifiedFileListFilter的弹簧集成文件轮询

我想知道是否有人会知道我是否可以在FileInboundChannelAdapter中使用Watch服务以及LastModifiedFileListFilter？下面的示例代码给了我相当不一致的结果。有时文件只是在文件夹中，并且保持未处理状态。我怀疑监视服务可能与LastModifiedFileListFilter不兼容。对于例如如果LastModifiedFileListfilter设置为

0热度

1回答

Spring集成头

我在Spring集成实现了一个简单的TCP连接工厂： @Bean @ServiceActivator(inputChannel = "toTcpChannel") public TcpSendingMessageHandler tcpOutClient() throws Exception { TcpSendingMessageHandler sender = new TcpSend

1热度

1回答

与MongoDbMessageStore的Spring集成聚合器：无法实例化GenericMessage：没有找到默认构造函数

我使用Spring Integration 4.3.11与Spring Data MongoDB 1.10.6。我有一个消息聚合器，使用MongoDbMessageStore。当从消息序列的消息进来，它坚持在MongoDB中，但紧接着（在o.s.i.store.AbstractMessageGroupStore#addMessageToGroup）当从MongoDB中读取 Failed to in

1热度

1回答

使用Spring Integration批量插入JDBC

我是Spring Integration的新手。我遵循几个文件，并使我的SI jdbc工作。现在我正试图查看我们是否可以用SI jdbc同时执行多个插入操作。要实现单个插入，我做了以下内容：接口与我的数据的方法有参数对象 SI XML与一个。频道 b。网关（接口详细信息） c。出站网关 - 数据库和查询详情 d。豆与键和值对有效载荷映射任何人都可以解释如何做一个SI jdbc的基本批量插入

2热度

1回答

Spring集成 - MongoDB的入站通道读取

我需要使用Spring集成查询到MongoDB的数据，我可以能够查询从MongoDB的，但同样的数据数据返回不止一次相同的数据， <bean id="mongoDBFactory" class="org.springframework.data.mongodb.core.SimpleMongoDbFactory"> <constructor-arg name="mongo"