spring-integration-dsl 相关问题

是否可以使用java注释在spring-integration中编写过滤器？

我正在尝试在spring-integration中转换xml配置，并且遇到了类似这样的过滤器： ] >> < [ 我不确定我是否完全理解你的问题。如果您使用注释，则其全部原因是因为您具有在SpEL中表达 cannot 或should not的一些复杂逻辑，因此它使您有机会编写一些Java代码并让框架知道这是一个过滤器。也有DSL，我认为这篇文章涵盖得很好-spring integration dsl filter instead filter method annotation

两个消息代理之间的Spring集成

我是Spring-Integration的新手。我的用例是：收听RabbitMQ队列/主题，获取消息，对其进行处理，然后将其发送给其他消息代理（大多数情况下将是另一个RabbitMQ实例）。 ...

如何避免流在处理程序返回null时停止？

我有以下配置：flow-> flow.handle（myHandler）.filter（p-> {log.warn（“已过滤过滤器”）;返回p！= null; ...

Spring集成java dsl错误，发现参数类型不明确

我是spring集成dsl的新手。作为学习的一部分，我将一种XML转换为Java DSL配置。这是xml配置的链接。 https：//dzone.com/articles/spring-integration -...

Spring集成流SFTP：模式过滤器不起作用

我有以下初始Spring集成流程：final var inboundStreamingAdapter = Sftp.inboundStreamingAdapter（new SftpRemoteFileTemplate（sftpSessionFactory））.patternFilter（“ * ....

Http.outboundGateway上的Spring Integration DSL OAuth

我对Spring-Integration有点陌生，一直在尝试POC一些简单的任务。从未接触过OAuth并需要OAuth提供休息服务，我希望有人可以向我展示...

如何使用wireTap传递标题？

现在我有以下流程：流程-> flow.channel（some_channel（））..... .gateway（anotherFlow，idempotentByHeader（OBJECT_ID_HEADER））;消费者

如何在Spring Cloud Stream项目中将传入的标头映射为String而不是byte []？]

我有一个简单的Spring Cloud Stream项目，该项目使用Spring Integration DSL流程并使用Kafka活页夹。一切正常，但是来自Kafka的消息头值以byte []的形式到达。这个...

我如何在Spring Integration中路由消息，在处理过程中抛出了异常？

我有以下集成流程：集成流程如果在解析器内部的第二个split方法期间引发了异常，我想将该消息传递给错误通道，是...

标头名称中带有“。”的标头注释，例如@Header（“ foo.bar”），不映射

我有一个带有签名的简单Spring Integration消息端点：@Transformer字符串handleMessage（@Payload字符串有效负载，@Header（“ nerf”）字符串nerf，@Header（“ foo.bar”）字符串foobar）{//。 ...

如何使用Spring Integration dsl在子流路径中转换字符串

我编写了一个非常简单的示例，在Spring中将路由与转换集成在一起，但是它提供了SpelEvaluationException。代码网关：@MessagingGateway @Component接口ApiGateway {@Gateway（...

如何在Spring Integration Flow中的threadlocal中注入变量

我需要在Spring集成流程中将callContext对象作为Local线程注入。应提取n在callContext对象中设置的jms标头中接收到的traceId，以便将其打印出来...

Spring Integration Kafka：入站通道适配器与消息驱动的适配器

我不熟悉使用Spring Integration Kafka。我在阅读文档，并在入站通道适配器和消息驱动的通道适配器之间感到困惑。可以解释一下...

使用Rest调用的Spring Integration丰富/转换消息

在Spring Integration中，我收到如下消息：{“ name”：“ House”，“ attributeIds”：[1,3,5]}我需要使用一些Rest Service丰富/转换此消息，这将给我...

IntegrationFlow HttpRequestHandlingMessagingGateway直接回复

我是Spring Integration的新手，我正在尝试使用HttpRequestExecutingMessageHandler和HttpRequestHandlingMessagingGateway。处理程序正在发送POST请求并期待答复。 ...

Spring集成 - 记录每个消息MDC到能够聚集消息

我使用SpringIntegration的IntegrationFlows定义消息流，并用Jms.messageDrivenChannelAdapter从MQ得到的消息，现在我需要解析它，将它发送到KAFKA和更新...

Spring Integration的事件监听站适配器

我有一个问题，我想实现使用DSL春季集成的输入适配器，作为一个事件监听器，并重定向从该事件侦听器消息的通道。所需的代码：@Bean ...

如何处理在Spring集成流FtpOutboundAdapter连接异常

我流的东西像结尾：.handle（，出ftpAdapters.rtwFtpOutboundHandler（） - > out.advice（后（）））获得（）;在咨询，我们有代码来处理：@Bean公...

Spring集成错误安装完成有效载荷

我有一个监听到JMS。当我阅读邮件，然后我转换到我的自定义对象的公共IntegrationFlow queueProcessorFlow（）{返回IntegrationFlows.from（Jms.inboundAdapter（...

setOnFailureExpression不工作的#root和#exception

后@Bean公共ExpressionEvaluatingRequestHandlerAdvice（）{logger.debug（ “评估表达意见。”）; ExpressionEvaluatingRequestHandlerAdvice咨询=新...