spring-integration

1热度

1回答

我找不到 http://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd 下 http://www.springframework.org/schema/integration/ 任何帮助？

1热度

1回答

Spring集成DSL相当于<INT：网关... />

什么是创造 <int:gateway service-interface="MyService" default-request-channel="myService.inputChannel"/> // where my existing interface looks like interface MyService { process(Foo foo); } 同等的Spring集成

1热度

1回答

Spring集成SocketException：连接重置

我的服务器代码：https://stackoverflow.com/a/41765722/3871754 我的客户端代码：https://alvinalexander.com/blog/post/java/simple-java-socket-client-class-program 当我运行客户端，我得到的服务器日志：o.s.i.i.tcp.connection.TcpNetConnection

1热度

1回答

Spring jpa：入站通道适配器配置

我尝试使用多个jpa：入站通道适配器。但是我有一个问题。当我添加两个入站通道适配器时，只有最后一个工作。例如，现在有两个入站通道，我们称它们为x和y。如果我先写x然后写y到application.xml文件，那么只有y有效。如果先写y，那么x只有x有效。这里是xml配置， <int:channel id="emailChannel" /> <int-jpa:inbound-channel-ada

1热度

1回答

带点符号的弹簧集成表达式映射访问

通常在Spring EL中，您可以使用方括号中的键通过其键访问映射条目。如果弹簧集成消息的有效载荷是java.util.Map，然后 payload['mykey'] 为您提供了具有字符串“我的钥匙”为重点的项的值。当使用标准的Spring EL设置时，例如，在单元测试中，这是使用地图的唯一方法。但是，在Spring集成流所使用的表达式中，我可以使用点符号来进行地图访问。这个作品： payl

1热度

1回答

添加动态HTTP标头WS出站网关

我想丰富自己的HTTP/SOAP请求（与WS出站网关发送）与根据一些自定义HTTP头什么实际Message包含，即增加基本身份验证每个请求，其中凭证依赖于某些Message.headers 添加自定义HTTP标头只有特定Message.headers存在我考虑了以下解决方案：实现自定义ClientInterceptor - 但目前还 Message.header用不上此时实现自定义Soap

0热度

1回答

春季集成 - 卡夫卡消息驱动通道 - 自动确认

我已经使用了春季io文档中列出的示例配置，它工作正常。 <int-kafka:message-driven-channel-adapter id="kafkaListener" listener-container="container1" auto-startup="false" phase="100" send-timeout="50

2热度

1回答

IMAP电子邮件通道适配器抛出异常“A5 BAD无效的命令或参数;”

我使用IMAP空闲通道适配器来接收春季整合电子邮件： A5 SEARCH NOT (ANSWERED) NOT (DELETED) NOT (SEEN) NOT (FLAGGED) ALL A5 BAD invalid command or parameters 似乎上面的IMAP服务器方面的命令无效，谁能告诉我如何解决？我调试消息： DEBUG: successfully loaded

0热度

1回答

春季集成 - 卡夫卡制片人错误频道

我正在使用卡夫卡制作人发布消息给其他卡夫卡主题，其工作相当好。下面的示例模板： <int-kafka:outbound-channel-adapter kafka-template="template" channel="inputToKafka" topic="foo"/> 请问上述声明支持errorchannel在卡夫卡消息驱动的入站通道适配

0热度

1回答

在Spring中传递来自属性文件的bean ID

我有一个springboot应用程序，它使用spring集成在多个组件之间路由tcp消息，它在功能POV中正常工作。我卡上的属性文件中声明的常量试图清理代码，并取代多个硬编码值（频道名称）：实际的例子由几个通道和路由器： <int:channel id="input"> <int:channel id="outputA"/> <int:channel id="outputB"/> <in