问题标签 [spring-dsl]

我正在努力配置 Spring Integration DSL 转换器使用的“自定义”ObjectMapper。我收到一个java.time.Instant我想解析为对象属性的 json 表示。即：
{“type”：“TEST”，“source”：“TEST”，“timestamp”：{“epochSecond”：1454503381，“nano”：335000000}}

该消息是一条 kafka 消息，它提出了一个问题：我应该编写一个自定义序列化程序来实现 Kafka 编码器/解码器，以便能够将 kafka 消息转换为正确的对象，还是 spring-integration 必须自动执行此操作？

固件/依赖项和版本：
Spring Boot - 1.3.2.RELEASE
Spring Integration Java Dsl - 1.1.1.RELEASE
FasterXml Jackson - 2.6.5

我已按照 Jackson 文档将此 Java 配置添加到项目中： https ://github.com/FasterXML/jackson-datatype-jsr310

以及以下 Jackson JSR-310 人工制品：

根据 Spring 博客上的这篇文章，我什至不必注册新的 Java8 时间模块。 https://spring.io/blog/2014/12/02/latest-jackson-integration-improvements-in-spring#jackson-modules

这是我得到的例外：

解决方案：
问题是我希望 Spring 会检测到 jackson-datatype-jsr310 原型并注册 JavaTimeModule，但事实并非如此，这完全没问题。有两种方法可以解决这个问题：
1. 如果我们按原样使用 Spring Boot 和 Spring Integration，则可以接受的答案。
2. 如果使用 Spring Integration Dsl，只需将 IntegrationConfiguration 类与 jsonObjectMapper() bean 一起保留并像这样使用它：

我一直在使用企业集成模式来处理 MQ 消息，进行一些处理，然后将它们写入另一个队列。

我的问题看起来与这个问题非常相似，但是接受的答案并没有为我解决。

在收到来自外部 Web 服务的响应后，我的@Cacheable @Component类将正文作为ArrayList. 我收到以下错误：

这是，我认为是，有问题的班级：

如您所见，我尝试设置公共 getter 方法，但仍然发生异常：

上下文.xml：

我正在使用 Spring Integration 来开发我的集成场景。当我必须写一些日志来提供一些信息时，我是这样写的：

我正在使用带有 lambda 和句柄的窃听器来记录我的消息。有没有更好的方法来使用 Java DSL 使用 Spring Integration 编写日志？

谢谢。

我正在尝试以批处理方式使用 Spring Integration 处理一系列文件。我有这个非常旧的 xml，它试图将消息转换为作业

这messageToJobTransformer是一个可以将 Message 转换为 Job 的类。问题是我不知道这个文件现在在哪里，我也不想要一个 xml 配置。我希望它是纯 Java DSL。这是我的简单配置。

这是我的网关 bean。

编辑：更新批处理配置类。

我开始为詹金斯工作（以前的工作流程）

我正在将 IntelliJ 用于 IDE

是否有 GDSL 的文档来源，或者我可以通过某种方式知道哪些 groovy 在管道中是可以接受的，哪些不是？

还有一种方法可以让我在检查我的 Jenkinsfile 之前测试运行 GDSL 吗？

所以我在骆驼弹簧 dsl 上有一些路线，它们的行为和工作方式与预期的一样。但是，当我在 karaf 上部署这些路线时，它们的行为会有所不同，例如 1) 我有这种情况<when><simple>${body} == null</simple></when>，即使在 karaf 中 body 是空的，它也会评估为 true

2) 我有一个处理器，用于检查 if(body != null) 条件是否为 true，即使 body 不为 null。

是否有任何具体原因使它在其他所有环境中都可以正常工作，但在 karaf 中却失败了。

我正在尝试将文件发送到远程 SFTP 服务器。我为此创建了一个工厂和一个 outboundFlow。

UploaderSftpConnectionFactoryBuilder

}

现在我想使用集成测试来测试出站流。为此，我在 testContext 下创建了：

测试上下文配置

我还按照@ https://github.com/spring-projects/spring-integration-java-dsl/blob/master/src/test/java/org/springframework/integration/dsl/test的建议创建了一个假的 sftp 服务器/sftp/TestSftpServer.java 下面是我的假服务器：

FakeSftpServer

最后下面是我的测试课

测试连接工厂

现在，当我运行此测试时，出现以下异常：

我无法解决它并坚持了很长时间。我是 spring-integration-dsl 的初学者，任何帮助都将不胜感激。

我想将文件发送到 SFTP 服务器。我为它创建了一个出站流

现在，当我尝试使用以下代码向此流发送消息时：

我收到以下错误：

请注意，当我将文件传递给如下 send 方法时，一切都像魅力一样：

我无法理解它的原因。请帮我解决这个问题。

对我来说，这似乎是最简单的 spring 集成示例。我正在尝试向si4demo学习。但是当我运行它时，我得到了这个异常：

线程“主”org.springframework.messaging.MessageDeliveryException 中的异常：调度程序没有频道“application.inbox”的订阅者。嵌套异常是 org.springframework.integration.MessageDispatchingException：调度程序没有订阅者

我哪里错了？定义的流程不会创建对收件箱频道的订阅吗？

我正在尝试使用 Spring Integration Java DSL 来接收电子邮件（gmail）。我也在使用 Redis。当我收到邮件时，我得到 ConcurrentModificationException 。在搜索时，我还发现人们在 Kafka 中也遇到了同样的错误。下面是我的代码和异常。

感谢您的帮助。

例外 ：