spring-integration相关内容
对于spring boot +集成应用程序,我正在尝试从数据库加载配置,允许Spring可以访问它的环境&可通过 @Value 注释注入,并可通过外部化配置覆盖,如外部化配置部分。 我遇到的问题是我的spring Integration XML包含 $ {input} 属性占位符,不能解决,因为我无法在之前加载数据库支持的配置 Spring尝试加载XML配置。 申请的入口点:
..
我想为我的邮件适配器配置一个轮询器,只运行一次或以编程方式运行它。 这是一个独立的应用程序( java -jar xxxx.jar),所以我想可能有一个选项是将固定利率属性配置为任意最大值然后退出应用程序,即: System.exit(0)。 是否有更多替代品或某种'正确' '对于这种情况?' 这是我的 integration-context.xml :
..
我正在尝试通过读取包含连接详细信息的属性文件来创建TCP服务器和客户端。 我在以下参考文档( 9.20动态和运行时集成流程) 创建客户端时代码工作正常但是当我使用相同代码中的更改创建服务器时,如下所示: IntegrationFlow flow = f - > ; f .handle(Tcp.inboundAdapter(Tcp.netServer(2221) .se
..
我有一个自我执行的jar程序,它在很大程度上依赖于Spring Integration。我遇到的问题是程序在其他Spring bean完成之前终止。 下面是一个简化版本的我正在使用的代码,如果需要,我可以提供更多的代码/配置。入口点是一个main()方法,它引导Spring并启动导入过程: public static void main(String [ ] args){ ctx
..
请参阅使用SSL / TLS运行客户端。这解释了服务器执行客户端身份验证的方案。我正在使用Spring Integration来处理TLS连接。我的spring-context文件是:
..
我正在尝试将自定义标头添加到我的http出站网关。 我尝试过的事情&工作:
..
我跟着这个在Spring中设置TCP客户端的示例。下面是变换器所在的 tcpClientServerDemo-context.xml 文件。有人可以帮我拆除变压器并按原样发送数据而不做任何修改吗?如果我尝试删除行 reply-channel ='clientBytes2StringChannel'或甚至将其设为null,我在构建项目时会遇到异常。
..
我们正在使用 Spring message-driven-channel-adapter 来订阅 MQTT 主题。但是我们经常遇到错误。我已使用JavaScript客户端( mqttws31.js )测试了连接,该工作正常。意味着连接没有问题。 错误: - org.springframework.integration.mqtt.inbound.MqttPahoMessageDriv
..
我使用XMLSpy编写以下XPath来确定最长的字符串长度,它在XMLSpy中工作: string-length (// exception:ElementMessageAbcException / @ exceptionMsg [not(string-length(。)
..
我在我的项目中使用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
..
我正在尝试使用spring integration sftp将文件转发到大型机:outbound-gateway: 这是配置:
..
我有一个Spring集成应用程序,附加到AMQP代理。 我想从amqp队列接收消息,并更新db记录。 为了提高性能,我有一个工作池允许同时进行多个更新。 我有以下内容配置:
..
我正在努力配置Spring Integration DSL变换器使用的“自定义”ObjectMapper。 我收到一个 java.time.Instant json表示我想要解析为对象属性。即: {“type”:“TEST”,“source”:“TEST”,“timestamp”:{“epochSecond”:1454503381,“nano”:335000000}} 该消息是一条k
..
我正在尝试使用Spring Integration和http outbound-gateway组合一个非常简单的HTTP POST示例。 我需要能够发送带有一些POST参数的HTTP POST消息,如我会用 curl : $ curl -d'fName = Fred& ; sName = Bloggs'http:// localhost 我可以让它工作(没有POST
..
我有存储在MongoDB中的文件,可以通过Rest服务上传/下载/删除。我想通过Spring Integration(+ Boot + Embedded Jetty)从MongoDB下载文件但我无法弄清楚如何正确设置Content-Disposition头,因为下载的文件具有正确的有效负载,但文件名错误(它是receiveGateway没有任何延期): xml config
..
首先,感谢关注 i在我的spring集成项目中定义的ftp适配器,并使用 mv 命令移动ftp服务器中的文件,目录结构是: ftp-root ----------- Directory1\ ----------- ------ in\ ---------------------------file.in ----------------- out \ 我想移动
..
我定义了一个使用spring-integration java dsl的流程来传输一个文件,处理它,然后将它传回一个“归档”目录,最后将它移入本地归档目录中。 这很“容易”: @Bean Public IntegrationFlow ftpInboundFlow(){ if(ftpProperties.getEnabled()== false){ return null; }
..
假设我有一个动态配置的tcp-ip连接工厂:
..
使用弹簧集成处理批处理时我遇到问题。 通常在分解器之后,所有元素(消息)将被分配一个相关符号以供将来在聚合器中进行分组,但问题是当处理元素(消息)时抛出异常时,将创建一个MeesageException并且correlation_id丢失。 我可以使用HeaderEnricher来添加correlation_id,但是它不能被硬编码我假设,如果有多个请求聚集在一起,事情会被组合在一起,一切
..