spring-integration相关内容

使用Spring Boot& Spring与数据库支持的Configuration集成

对于spring boot +集成应用程序,我正在尝试从数据库加载配置,允许Spring可以访问它的环境&可通过 @Value 注释注入,并可通过外部化配置覆盖,如外部化配置部分。 我遇到的问题是我的spring Integration XML包含 $ {input} 属性占位符,不能解决,因为我无法在之前加载数据库支持的配置 Spring尝试加载XML配置。 申请的入口点: ..
发布时间:2019-01-08 18:46:11 Java开发

Spring集成邮件轮询器

我想为我的邮件适配器配置一个轮询器,只运行一次或以编程方式运行它。 这是一个独立的应用程序( java -jar xxxx.jar),所以我想可能有一个选项是将固定利率属性配置为任意最大值然后退出应用程序,即: System.exit(0)。 是否有更多替代品或某种'正确' '对于这种情况?' 这是我的 integration-context.xml : ..
发布时间:2019-01-08 13:34:21 Java开发

使用Java DSL进行Spring集成的动态TCP服务器

我正在尝试通过读取包含连接详细信息的属性文件来创建TCP服务器和客户端。 我在以下参考文档( 9.20动态和运行时集成流程) 创建客户端时代码工作正常但是当我使用相同代码中的更改创建服务器时,如下所示: IntegrationFlow flow = f - > ; f .handle(Tcp.inboundAdapter(Tcp.netServer(2221) .se ..

等待所有线程在Spring Integration中完成

我有一个自我执行的jar程序,它在很大程度上依赖于Spring Integration。我遇到的问题是程序在其他Spring bean完成之前终止。 下面是一个简化版本的我正在使用的代码,如果需要,我可以提供更多的代码/配置。入口点是一个main()方法,它引导Spring并启动导入过程: public static void main(String [ ] args){ ctx ..
发布时间:2018-12-28 20:45:46 Java开发

没有Transformer的Spring TCP客户端

我跟着这个在Spring中设置TCP客户端的示例。下面是变换器所在的 tcpClientServerDemo-context.xml 文件。有人可以帮我拆除变压器并按原样发送数据而不做任何修改吗?如果我尝试删除行 reply-channel ='clientBytes2StringChannel'或甚至将其设为null,我在构建项目时会遇到异常。 ..
发布时间:2018-12-24 12:51:11 Java开发

java.lang.ClassNotFoundException:org.springframework.http.converter.json.MappingJackson2HttpMessageConverter

我在我的项目中使用spring-integration。当我在jetty容器中部署我的应用程序时,我遇到以下异常: org.springframework.beans.factory.BeanCreationException :创建名为'integrationRequestMappingHandlerMapping'的bean时出错:bean的初始化失败;嵌套异常是org.springf ..

远程分区 - 奴隶变得贪婪

以下是我们正在努力实现的目标。 我们希望在不同的vms中并行地在数据库中暂存一个大的xml文件。为实现这一目标,我们正在使用可扩展的Spring批量远程分区方法,我们遇到了一些问题。以下是高级别设置 master - 将xml文件拆分为多个分区(我们目前的网格大小为3)。 slave 1 - 处理分区(读取基于索引的分区并写入DB) slave 2 - 处理分区 我们在L ..
发布时间:2018-12-21 21:13:06 Java开发

spring集成入站网关http请求标头

我有存储在MongoDB中的文件,可以通过Rest服务上传/下载/删除。我想通过Spring Integration(+ Boot + Embedded Jetty)从MongoDB下载文件但我无法弄清楚如何正确设置Content-Disposition头,因为下载的文件具有正确的有效负载,但文件名错误(它是receiveGateway没有任何延期): xml config ..
发布时间:2018-07-09 15:42:42 其他开发

在使用Java DSL成功传输ftp后移动文件

我定义了一个使用spring-integration java dsl的流程来传输一个文件,处理它,然后将它传回一个“归档”目录,最后将它移入本地归档目录中。 这很“容易”: @Bean Public IntegrationFlow ftpInboundFlow(){ if(ftpProperties.getEnabled()== false){ return null; } ..
发布时间:2018-04-13 13:50:08 Java开发

弹簧整合抛出异常与相关标识

使用弹簧集成处理批处理时我遇到问题。 通常在分解器之后,所有元素(消息)将被分配一个相关符号以供将来在聚合器中进行分组,但问题是当处理元素(消息)时抛出异常时,将创建一个MeesageException并且correlation_id丢失。 我可以使用HeaderEnricher来添加correlation_id,但是它不能被硬编码我假设,如果有多个请求聚集在一起,事情会被组合在一起,一切 ..
发布时间:2017-09-30 23:06:11 其他开发