问题标签 [spring-integration-jdbc]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

14 问题
Newest
Active
Bountied
318
Unanswered
0 投票
0 回答
18 浏览

spring-kafka - 如何访问 SCDF 流中的源本机标头？

我正在使用 SCDF 开发一个流，允许将所有 MQTT 消息持久化到 SQL 数据库。

这是用于创建流的代码

mqtt_message 表包含几列，其中包括 headers、payload、received_topic。流已成功部署并且数据被持久化，但是：headers列是使用 SpEL headers.toString() 提取的：

使用SpEL payload.toString() 很好地提取了有效负载列：

如您所见，标头中的值不包括假定的标头，包括消息的主题 (mqtt_receivedTopic)。

如果我为生产者和接收器提供实现，我可以访问以下消息头：

我还测试了以下属性，但它们都没有改变结果：

制片人

  • spring.cloud.stream.bindings.output.producer.headerMode=embeddedHeaders
  • spring.cloud.stream.bindings.output.producer.useNativeEncoding=true

消费者

  • spring.cloud.stream.default.consumer.headerMode=embeddedHeaders

有没有办法在生产者和接收器之间传递本机标头并将它们写入目标列（从接收到的主题中提取值）。

谢谢。

0 投票
0 回答
25 浏览

spring - 使用 JDBC 的 Spring Integration 消息传递应用程序

我是 Spring 集成和消息传递通道的新手，请您帮助我处理 JDBC Spring 集成消息传递通道。

我创建了 3 个应用程序 Poller 、 Executor 和出站通道，但我很困惑这 3 个应用程序将如何通信和发送消息。

如何使用 .xml 从 xml 下方配置请求通道和回复通道IngrationFlow。

我的代码 -

如何在上面的代码中配置请求通道和回复通道，并将有效负载发送到回复通道。

0 投票
1 回答
27 浏览

spring - JdbcMetadataStore：初始化模式，但对于不使用 Boot 的 Spring 应用程序

版本：

我已经实现了一个纯 Spring 5.x webapp；没有 Spring Boot。

我正在使用JdbcMetadataStore并要求使用位于类路径中的模式定义初始化 PostgreSQL 数据库：

在关于该主题的一篇非常有用的文章之后，以下是我放入的属性spring.properties：

这不起作用。经过研究这个问题，我了解到启动初始化是支持的，但是在 Spring Boot 中。

问题：没有在 webapp 初始化期间在其他地方显式处理此 SQL 脚本的执行，是否有任何标准方法可以在启动时加载上面列出的脚本？注意：我没有使用schema.sql脚本或类似的东西来初始化我的后端。

0 投票
1 回答
32 浏览

spring-integration - spring integration 5.5.x如何使用mysql作为消息存储

我正在使用 Mysql 作为消息存储数据库，刚刚尝试升级到 Spring Integration 5.5.5，但发现架构发生了变化，CONDITIONINT_MESSAGE_GROUP 表中需要一列，虽然我可以通过添加反引号来创建表CONDITION，但有一个 sql在 JdbcMessageStore.java 中

它不能工作吗？任何解决方法？


12345678910