问题标签 [spring-dsl]

我正在尝试将文件上传到远程 SFTP 服务器。我从同一个创建了出站流

我的 cachedSessionFactory 看起来像::

服务启动上传::

调用服务时，调试日志显示以下跟踪：

更高级别的错误如下所示：

我究竟做错了什么？它让我坚持了几天。任何帮助都深表感谢。

我是apache骆驼的新手。我想通过发出 jetty Post 请求来使用 apache camel 创建服务总线（中间件），然后从服务器获取响应。

这是我所做的

请求成功发送到服务器并提交我的案例，否则我无法从服务器获取响应。

注意：响应来自服务器是字符串它来自这样的'code'：0，'description'：'操作成功完成'，'complaintId'：'45285'

感谢提前

我有一个具有多个进程的（旧版）TCP 服务。每个进程在同一主机上运行，​​但在不同的端口上。该服务是单线程的，因此增加吞吐量的方法是在每个端口上循环每个请求。

我正在为这个遗留应用程序提供 AMQP 暴露。它非常简单——从 AMQP 队列中取出一个字符串，将其传递给应用程序，然后将响应字符串返回给 AMQP 回复队列。

这在单个端口上效果很好。但是，我想分散所有端口的请求。

Spring Integration 似乎只提供AbstractClientConnectionFactory直接连接到单个主机/端口 ( TcpNetClientConnectionFactory) 或维护到单个主机/端口 ( CachingClientConnectionFactory) 的连接池的实现。单个主机和多个端口之间没有任何池连接。

我试图编写我自己的AbstractClientConnectionFactory来维护AbstractClientConnectionFactory对象池和它们之间的循环。但是，当目标服务消失或网络中断时，我遇到了几个我无法解决的处理 TCP 连接的问题。

这个问题也采用了方法：Spring Integration 4 - 在 Java DSL 中配置 LoadBalancingStrategy，但解决方案是硬编码端点的数量。就我而言，端点的数量仅在运行时才知道，并且是用户可配置的设置。

因此，基本上我需要在运行时动态TcpOutboundGateway创建每个端口，并以某种方式将其注册到我的. 我尝试了以下方法：IntegrationFlow

有谁知道我该如何解决这个问题？

我使用 spring 集成从数据库中读取数据。现在我使用轮询适配器

流动：

但我想从其他系统安排我的流程。有人知道怎么做吗？

我正在使用 SI-DSL 编写一个 SI 流程，所以让我先说我不知道​​这个问题是仅与 Si-DSL 相关还是与 SI 和 SI-DSL 相关。

我的用例是这样
的 - 从队列中获取消息 - 将消息保存在数据库表中 - 通过在未来某个时间点选择处于某个特定状态的消息来检索这些消息 - 进一步处理消息......

我的问题是第三步。如果第 3 步是第 1 步，这将很容易，因为我可以只使用 JdbcPollingChannelAdaptera 作为 MessageSource。但是，我找不到在流程中间使用的方法。所以，在 DSL 术语中，我可以做到（其中 dbDataMessageSource 是 JdbcPollingChannelAdapter）

但我做不到

我尝试使用网关、网桥、handleWithAdapter 而不是“.handle”，但注意到有效。

有任何想法吗？

干杯。

以以下场景为例：我通过迭代器拆分消息。.handle()如果在迭代一个元素时抛出异常，则跳过所有剩余元素并获取下一条消息。我需要抑制任何可能的异常，以便处理迭代器中的所有元素。

例如，由于我使用的是迭代器而不是列表，因此我无法使用.aggregate().

请问，我怎样才能获得所需的行为......？

• Spring Boot Starter 集成 1.3.0
• Spring 集成 4.2.1
• Java DSL 1.1.1

提前致谢！

我正在尝试从文件系统中获取 JSON 文件，并尝试将文件插入 MarkLogic 数据库。

用户名和密码为：admin/admin 用于在 8005 上运行的 MarkLogic REST 实例

我正在尝试使用一组配置的 RSS 提要编写 RSS 提要阅读器。我认为一个好的方法是通过编写原型来解决这个问题，@Bean并使用配置中的每个 RSS 提要调用它。

但是，我想我在应用程序启动时在这里遗漏了一点，但什么也没发生。我的意思是豆子是按照我的预期创建的，但是在该方法中没有发生日志记录handle()：

这里缺少什么？似乎我需要以某种方式“启动”流程。

我目前正在开发一个大量使用 Camel 的应用程序。我将简要解释我想要实现的目标：

OnException 处理器 (handled=true) 捕获异常，当发生这种情况时，我想阻止 Exchange 被路由的 RoutePolicy(s) 处理。伪代码示例：

因此，从本质上讲，一旦处理了异常，我希望 Exchange 停止传播到所有附加的策略。

想知道是否有一种简单的方法可以实现这一点，我在阅读文档时可能会错过。

就是这样。干杯。

示例应用程序位于此处：https ://github.com/rushidesai1/Grails2_4_2_BeanIssue

问题：

如果我们在 resources.groovy 中声明一个这样的 bean

现在，如果我们 DI testObject bean 或执行 'Holders.grailsApplication.mainContext.getBean("testObject")'，那么我们得到的 bean 将具有单例 'map' 和单例 'testA' 对象。

这里 testObject 被声明为“原型”，即使这样，“地图”和“测试A”都是单例的

我想知道这是一个错误还是按设计工作。它会像这样工作是完全违反直觉的，因为我们专门做新的，所以我们希望每次都注入一个新的 bean。

使用单元测试用例查看我的问题的更详细版本。

提前感谢您的澄清！