spring-integration

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

2热度

1回答

存储过程传出网关没有返回的DB2数据库的所有ResultSet

我们正在使用DB2 database.I已经通过以下方式配置的stored-proc-outbound-gateway： <int-jdbc:stored-proc-outbound-gateway auto-startup="true" data-source="routingDataSource" stored-procedure-name="ZSPP

1热度

1回答

任务执行程序不停止

在我的代码中：spring-integration，分散收集通道在那里，散射通道使用任务执行程序并行地调用两个微服务并收集收集通道中的响应。我使用记录器通道在分散采集通道中记录请求响应。我可以看到来自两个服务的响应来收集频道，但坚持不去下一个频道。如果我不使用线程（任务执行程序），我怀疑收集通道的发布策略可能无法正常工作，但同样工作。建议一些东西。谢谢。

0热度

1回答

如何在http：outbound-gateway中配置post参数

我们有一个案例，通过使用http post调用从客户系统中检索订单，post请求包含用户名和密码，然后我们可以获得订单内容响应。我们想每10分钟致电客户的服务，然后在我们的服务激活器中处理响应，但是我不知道如何在弹簧集成配置中将用户名和密码配置为发布参数，任何人都可以提供帮助？我目前的配置 <int:inbound-channel-adapter channel="inChannel" exp

0热度

1回答

在Spring集成中将json请求参数设置为http标头

我需要将soap安全用户名和密码动态地传递给出站网关。为此，我尝试将接收到的json请求中的用户名设置为入站http头，然后将其设置为header-richher作为soap动作并将其用于定制的Wss4jSecurityInterceptor拦截器中。当我试图设置为HTTP标头我得到的例外是：嵌套例外是： org.springframework.expression.spel.SpelEvalu

1热度

1回答

春季集成jdbc oubound网关选择查询返回只有一个记录

我想从数据库使用弹簧集成jdbc出站网关提取记录。我在数据库中有很多记录，但以下代码仅返回有效内容中的一条记录。 <int-jdbc:outbound-gateway query="select * from payee" request-channel="input" reply-channel="output" data-source="dataSource"/>

0热度

1回答

如何将XML事件传递给Apache Kafka？

我的组织中有一个集群（2节点）CRM应用程序，它使用Spring集成框架（v2.2.0）在执行操作时发布事件，例如，创建一个请求，创建一个客户等等。目前这些事件只是去了一个NULL通道，但是我想开始将它们转发到在同一网络上运行的Apache Kafka实例。从那里我想对数据做进一步的处理和分析，以使用其他组件创建实时报告。我已经看了一下spring-integration-kafka项目，但它

0热度

1回答

春季集成：保留http错误代码和正文作为回应

我有一个入站http网关，它的传入消息传递到出站http网关（使用集成java dsl）。当出站网关响应的http状态为200时，出站响应将按照预期返回到入站网关的调用者。但是当出站网关响应特定的客户端错误（如423锁定或403禁止）时，入站网关的调用者会收到500以及包含异常字符串的主体消息。据我所知，这是因为SI处理出站http错误作为例外。但在我的情况下，我需要将出站响应附带的响应主体

1热度

1回答

重复跨度弹簧整合

请求通道是一个分散通道。向3个微服务（出站网关）发送请求。我期待不同的服务范围能够正确跟踪不同的服务。我正在使用春天的侦探。使用DefaultHeaderMapper来映射标题。我的问题是： 1.如何生成span id，服务器/客户端在哪里？任何参考文件要研究。 2.如何解决弹簧一体化中重复跨度的问题？