spring-dsl

2热度

1回答

我想将流程的特定部分作为事务处理。例如，我想在前两个变换操作中使用一个事务性块。下面是我用的流量代码： @Bean public IntegrationFlow createNumberRange() { return IntegrationFlows.from("npEventPubSubChannel") .transform(...) .trans

0热度

1回答

如何从报头值在Apache的骆驼设置队列名称

我试着从报头值设置ActiveMQ的队列名称，但其不低于发生的事情是我春DSL <setHeader headerName="x-so-queue-name" id="_setHeader1"> <xpath resultType="java.lang.String">/Message/@IntObjectName</xpath> </setHeader> <log id="_lo

1热度

1回答

创建sftp回复通道，回复错误或发送失败的消息

我正在使用java dsl配置sfp出站流。网关： @MessagingGateway public interface SftpGateway { @Gateway(requestChannel = "sftp-channel") void sendFiles(List<Message> messages); } 配置： @Bean public IntegrationFlow

1热度

1回答

如何使用DSL跳过springcloudstream文件的标题行（第一行）？

我正在使用Spring云流来读取文件并使用文件分割器进行分割，并使用DSL样式将每行作为消息发出，正在读取的文件有一个标题行，只是想知道是否有一种简单的方法可以跳过标题行读/读之前/之后。任何帮助表示赞赏。这里是我的分配器和integrationFlow的样子： enter code here return IntegrationFlows .from("....")

0热度

1回答

问题与骆驼定制@Converter使用春季DSL

我只想学习自定义转换器并遇到问题。任何帮助深表感谢。骆驼版本2.17和JBoss保险丝6.3 @Converter public class MyConvertor{ public MyConvertor(){} @Converter public static String convertTo(Exchange exchange) {} } 在我的春天

1热度

2回答

为链中的每个处理程序分配不同的错误处理程序

我有一个应用程序指定一个简单的流，其中需要按特定顺序调用一系列服务来执行某些功能。 Spring集成和它的DSL似乎适用于这种情况。这些个别服务中的任何一个都可能失败（这些服务是对外部应用程序的调用），此时链应该停止。不仅如此，控制流也需要重定向到其他地方，具体取决于失败的服务。换句话说，我需要为每个服务提供不同的错误处理程序。问题是我很难找到如何做到这一点，如果有人能指出我正确的方向，我将非

0热度

1回答

骆驼分配器商店CamelSplitSize，失败

http://camel.apache.org/splitter.html [1] 从[1]链路只见CamelSplitSize将在已完成的交易处理的行。我学习骆驼，我想知道的是有可能的方式来分割包含100行的xml文件（假设100行）如果分割在处理第50行的失败，我们需要显示CamelSplitIndex 50，CamelSplitSize 100和CamelSplitComplete假 .

0热度

1回答

ActiveMQ内的路由逻辑到特定的工作池

我有一个场景，我有相同的队列配置为SMS和EMAILS。我希望ActiveMQ将消息路由到特定的使用者池，即如果它是SMS，则必须将其路由到工作线程池以用于SMS。所以，如果我需要扩大SMS的数量，那么我只需要增加SMS Worker Pool的池大小而不是EMAIL工作池。我可以使用Apache Camel来实现我的需求的路由逻辑吗？

0热度

1回答

spring-integration-dsl：使Feed-Flow工作

我正在尝试使用一组已配置的RSS-feeds对RSS阅读器进行编码。我认为一个好方法就是通过编码原型来解决这个问题 - @Bean并用配置中找到的每个RSS提要调用它。但是，我想我在应用程序启动时忽略了一点，但没有任何反应。我的意思是豆创建为我所期待，但没有记录在handle() - 方法发生： @Component public class HomeServerRunner implemen

-1热度

2回答

如何使用任意地图（动态对象）创建DSL Groovy配置文件

如何将任意Groovy地图/列表转换为Groovy提供的配置样式DSL语法？例子： def config = [ 'test': 'lalala', 'nestedObject': [ foo1: 'foo1 val', foo2: 'foo2 val', nested2: [ anInt: 5, anArray