Spring集成消息通道ID
我需要在我的Spring集成上下文中动态地将消息分配给MessageChannel。当我知道我想要的MessageChannel的名称时，我可以通过从上下文中获取MessageChannel bean来做到这一点。
我需要做的是通过编程查找在ChannelAdapter/服务中设置的消息通道的名称/id。
但是，MessageChannel API没有与之关联的getName（）或getId（）方法。
有没有办法找到这条信息？
提前谢谢。
共有1个答案
让我们从另一个角度来看看这个任务！
处理如此低的API（如通道）的原因是什么？
为什么不在这件事上使用路由器模式？
如果我理解正确，您需要一些dinamic路由，通过一些消息属性确定目标频道。
因此，使用表达式路由器可能就足够了：
<int:router input-channel="input" expression="payload.theChannel"/>
-
我使用了spring io文档中列出的示例配置，它运行良好。 然而，当我用下游应用程序测试它时，我从Kafka那里消费并将其发布到下游。如果下游关闭，则消息仍在使用中，不会重播。 或者说，在使用kafka主题后，如果我在service activator中发现一些异常，我还想抛出一些异常，这些异常应该回滚事务，以便可以重播kafka消息。 简而言之，如果消费应用程序有一些问题，那么我想回滚事务，这
-
使用Spring Integration Kafka，使用出站通道适配器，我尝试向名为“test”的主题发送消息 通过命令行终端，我启动了动物园管理员、kafka并创建了名为“test”的主题 Spring XML配置 JUnit测试代码 测试用例成功，在调试时，我发现channel.send()返回true 我使用下面的命令通过命令行检查了主题，但是我在测试主题中看不到任何消息。 bin/kaf
-
我是Spring集成的新手，正在研究一个从单个通道向多个通道发送消息的示例，从这个角度来看，为每个通道使用Redis消息存储，目的是不丢失任何消息。要求将消息发送到通道-replyChannel、mailChannel和dbChannel。目前，代码只打印sysout语句，没有主要功能。 为了检查消息是否被正确路由，我编写了一个java测试类来发送15条消息。 检查输出，我发现一些消息正在丢失。也
-
我有一个集成应用程序，大部分工作，但注意到昨天一个消息丢失了。当时，service-activatorendpoint正忙于处理先前的消息。 以下是适用于该问题的配置。
-
我是Spring集成的新手 我的目标是将信息从一个渠道传递到另一个渠道(链式过程) 通道1--- 1. 尝试： 1.当我尝试使用@transformer无法与“erroeChannel”通信时。 问题： 找到答案 } 其他通道代码也是如此
-
我在我们的项目中引入了spring集成，而不是遗留集成架构。该体系结构支持发送者和累犯。每个发件人可以配置3个目的地。 null Spring integration gateways看起来很合适。我可以使用default-request-channel来表示主流，error-channel来表示失败流。备份流的问题。如何复制网关传入消息并将其放置到备份通道？ 更准确地说，这里是一个测试和代码。