Spring集成@ServiceActivator或@Bean定义以支持@Profile使用

Question

我对服务激活器的用法及其定义方式有疑问。

我有3个服务激活器，它们从不同的输入通道接收消息，并将它们发送到单个输出通道。这是在"dev"环境下设计的...

@ServiceActivator(inputChannel = "irregularMessageChannel_1", outputChannel = "combinedChannel")
public String handlerSite1(String data, @Header(IpHeaders.IP_ADDRESS) String connectionId) {
    if (log.isDebugEnabled())
        log.debug("content received from : {} data : {} ", connectionId, data);
    return data;
}

@ServiceActivator(inputChannel = "irregularMessageChannel_2", outputChannel = "combinedChannel")
public String handlerSite2(String data, @Header(IpHeaders.IP_ADDRESS) String connectionId) {
    if (log.isDebugEnabled())
        log.debug("content received from : {} data : {} ", connectionId, data);
    return data;
}

@ServiceActivator(inputChannel = "irregularMessageChannel_3", outputChannel = "combinedChannel")
public String handlerSite3(String data, @Header(IpHeaders.IP_ADDRESS) String connectionId) {
    if (log.isDebugEnabled())
        log.debug("content received from : {} data : {} ", connectionId, data);
    return data;
}

但在prod或prepod环境中，我需要再添加一个。。。因此，我选择使用@Profile注释和@ServiceActivator，如下所示

@ServiceActivator(inputChannel = "irregularMessageChannel_X", outputChannel = "combinedChannel")
@Profile("prod")
public String handlerSiteX(String data, @Header(IpHeaders.IP_ADDRESS) String connectionId) {
    if (log.isDebugEnabled())
        log.debug("content received from : {} data : {} ", connectionId, data);
    return data;
}

但是据我所知，@Profile不能与@ServiceActivator一起工作，它也需要@Bean定义。

但是

当我谷歌了它，它写着，如果我使用@Bean定义，我应该返回MessageHandler...我只是创建MessageHandler并返回它...

@Bean
@ServiceActivator(inputChannel = "irregularMessageChannel_X",outputChannel = "combinedChannel")
@Profile("prod")
public MessageHandler handlerSiteX() {
    MessageHandler handler = new MessageHandler() {
        @Override
        public void handleMessage(Message<?> message) throws MessagingException {
            if (log.isDebugEnabled())
                log.debug("content received from : {} data : {} ", message.getHeaders().get(IpHeaders.IP_ADDRESS), message);
        }
    };
    return handler ;
}

问题第1部分

现在我有一个问题，我如何才能像@ServiceActivator中使用的那样将消息发送到输出通道？

与@Bean注释一起，不允许在@ServiceActivator中使用outputChannel属性。或者有没有办法在不使用@Bean但使用@ServiceActivator的情况下使用@Profile注释？

编辑

问题第2部分

我也应该自己创建输入通道吗？如果使用@Bean定义，还是像@ServiceActivator一样自动创建？

谢谢你的帮助。

Answer 1

你必须赢得客户的信任，这就是为什么你必须利用你的资源来提供一个优秀的定制包装解决方案。定制的包装解决方案需要指定，因此，您需要使用具有卓越最高质量的个性化产品包装。定制包装

Answer 2

只能在@Bean上使用@Profile，而不能在@ServiceActivator方法中使用@Bean。

请参见@Bean方法的注释。

您的@Bean应该如下所示：

@Bean
@Profile("...")
@ServiceActivator(inputChannel = "...")
public MessageHandler profiledHandler() {
    ServiceActivatingHandler handler = new ServiceActivatingHandler(myServiceBean, 
        "handlerSiteX");
    handler.setOutputChannelName("combinedChannel");
    return handler;
{

输出通道在处理器上运行；是，如果需要，将创建输入通道。