我想订阅一个pubsub频道，以获取所有消息负载并处理它们。问题是，我看到了 IntegrationFlow ，但如果我理解正确，则使用integrationflow从一个通道获取数据，然后发送到另一个通道。我不想发送到另一个频道，我只想得到有效载荷，处理它。我该怎么做？我找到的所有示例都使用xml文件进行配置，但项目不是用这种方式创建的。
IntegrationFlow
xpszyzbs1#
我看到了integrationflow的例子，但如果我理解正确，integrationflow将用于从一个通道获取数据，然后发送到另一个通道。我认为这是不正确的信息。你可以处理这些信息。您可以在配置类中执行以下操作：
@Bean public IntegrationFlow myFlow() { return IntegrationFlows.from(...) .handle((GenericHandler<YourMessage>) (message, headers) -> {...}) }
1条答案
按热度按时间xpszyzbs1#
我看到了integrationflow的例子，但如果我理解正确，integrationflow将用于从一个通道获取数据，然后发送到另一个通道。
我认为这是不正确的信息。你可以处理这些信息。您可以在配置类中执行以下操作：