spring-integration

1热度

1回答

想要提出一个更广泛的问题，例如，如何最好地管理集群式的Spring集成应用程序，例如典型的AWS ALB。领导人选举：这是支持与SI与角色和领导人选举的API https://docs.spring.io/spring-integration/reference/htmlsingle/#leadership-event-handling，我想它有良好的支持，每https://docs.sprin

0热度

1回答

我可以在独立应用程序中使用弹簧集成吗？

我是新来的弹簧集成，并想知道我是否可以在独立的应用程序中使用弹簧集成。各种服务或工作流通过发布消息通过渠道进行通信。我想要控制应用程序的装饰流程，并且我发现弹簧集成在这方面非常有趣。请指教。

0热度

1回答

Spring集成设计 - 在

我想了解“最好”的方式来实现这一目标，文件处理线：使用FileReadingMessageSource作为文件源的每一行（使用FileSplitter）增加的数据行并向其他服务器发送REST请求并等待响应。现在发送REST请求不是一个转换，我不认为它是一个适配器，而不是一个路由器。这是什么？什么是设计这个的正确方法？

0热度

1回答

插入POJO到弹簧集成数据库

我有一个pojo，我想插入到数据库（Sql Server）。当我运行我的代码时，我得到了“从UNKNOWN到UNKNOWN的转换不受支持”。我的问题是，如果我的pojo和我的数据库的所有命名都一样，我可以直接写这个（或者是否有注释让我这么做）？或者我在这里总是需要一个bean来做映射吗？我在想这个错误可能是因为我在一个不属于它的地方干扰了它。在我的主类我有 @Inject TradePersi

0热度

1回答

如何扩展TCP出站网关，以便在Spring集成中只接收消息

我正在开发一个支持通过Spring Integration进行TCP连接的Web应用程序。它有两个功能。将消息发送到服务器，并在同一时间接收来自服务器的答复刚刚收到来自服务器的消息（在服务器上的应用程序不是由Spring集成开发。）在在这种情况下，应使用TCP适配器，并且我需要提供协作TCP出站和入站通道适配器。但是，我的应用程序有一些限制。此应用程序没有数据库。消息的有效载荷格式

0热度

2回答

如何使用大缓冲区设置HTTP出站网关发送请求

我使用Spring Integration 4.3.9.RELEASE和Apache HTTP组件HttpClient（4.5.2）将包含300k上传文件的请求中继到后端服务。有时整个配置工作正常。但有时它表现不佳，而且它将需要将近10分钟才能发送请求并获得回应。我使用纯Java编写了一些测试（请参阅Sending HTTP POST Request In Java），结果如下。 +-------

1热度

1回答

与tibco Rendezvous弹簧整合

我正在使用需要连接到Tibco RV messaging system（Not Tibco EMS）主题的独立弹簧引导应用程序。我想知道是否有办法将春季应用程序与Tibco RV消息系统连接起来？无论我看到的是使用Tibco EMS的例子，但无法找到任何关于在Tibco RV等对等消息系统中连接弹簧应用程序的文档。任何形式的帮助，将不胜感激。

1热度

1回答

Spring-Integration-DSL和Soap服务Soap头没有被调用

我想调用一个肥皂服务与春天集成DSL，有一些自定义头需要添加。构建marshellingoutboundgateway。尝试覆盖DefaultSoapHeaderMapper，但没有重写的方法被调用。试图构建这样的事情。 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"> <soap

1热度

1回答

Spring集成 - 跨步骤共享锁定

我有以下设置：许多设备通过HTTP将数据发送到我的后端，其中接收器组件正在运行多个实例。我需要处理数据，然后将其发送给另一个外部合作伙伴，他们需要按时间戳顺序输入此数据。于是我想出了以下结构：有运行，在他们面前的一个负载均衡N个接收机的情况下，让他们potientially得到所有设备的数据。这些实例通过添加一些信息来处理每个传入数据，然后将数据放入Redis Sorted Set（每个设备都有

0热度

1回答

如何在聚合器后定义链中的异常路由器

我使用Spring集成将消息聚合为一个，然后通过FTP发送绑定适配器，我想在出站FTP服务器不可用时将聚合消息移动到特定文件夹中org.springframework.messaging.MessageDeliveryException），其他异常将通过控制台记录。这里是我的配置 <int:chain id="transformChain" input-channel="inboundChann