在使用outbound jms适配器时，我们可以根据MessageHeaders动态选择JmsTemplate吗？

Question

我创建了 2 个jmsTemplate Bean 以便能够相应地处理向Solace Queue 和Solace Topic 发送消息，现在当我在下面的exampleChannel 上传递消息时，我想如果MessageHandler 可以动态选择 jmsTemplate ？如果我用MessageHeader 传递消息，可以说destinationType=Topic/Queue

下面是配置

    @Autowired
    @Qualifier("topic")
    private JmsTemplate jmsTemplate;
    
    @Autowired
    @Qualifier("queue")
    private JmsTemplate jmsTemplate1;

    @Bean
    @ServiceActivator(inputChannel = "exampleMessageChannel" )
    public MessageHandler archiveOutboundHandler() {

        /*
         I need to select between jmsTemplate & jmsTemplate1 on the basis on header 
         information. 
         **/
        JmsSendingMessageHandler messageHandler = new JmsSendingMessageHandler(jmsTemplete);
        messageHandler.setDestinationExpression(new FunctionExpression<Message<?>>(m->m.getHeaders().get("destination")));
        return messageHandler;
    }

有可能吗？或者有更好的方法吗？

更新 1：

@Artem 建议将destinationExpression 的实现更改为返回Destination 后，我这样做了

    @Bean
    @ServiceActivator(inputChannel = "outMessageChannel" )
    public MessageHandler archiveOutboundHandler() {
        JmsSendingMessageHandler messageHandler = new JmsSendingMessageHandler(jmsTemplate);
        messageHandler.setDestinationExpression(new FunctionExpression<Message<?>>(message -> {
            if((Objects.equals(message.getHeaders().get("destinationType"), "topic"))){
               return (Topic) () -> (String) message.getHeaders().get("destination");
            }else{
                return (Queue) () -> (String) message.getHeaders().get("destination");
            }
        }));
        return messageHandler;
    }

我遇到了异常

$$Lambda$821/1572602632 cannot be cast to com.solacesystems.jms.SolDestination)

更新 2

我能够使用JndiDestinationResolver解析目的地

正如 Artem 建议使用 BeanFactoryDestinationResolver 那样，我无法使用它，因为目的地太多，BeanFactoryDestinationResolver 需要为每个目的地创建特定的 bean。

我已经配置了JndiDestinationResolver，所以我只需要注入DestinationResolver 来解析目的地。

下面是sn-p，

@Autowired
private JmsTemplate jmsTemplate;

@Autowired
private DestinationResolver destinationResolver;

@Bean
@ServiceActivator(inputChannel = "exampleChannel" )
public MessageHandler jmsOutboundHandler() {
    
    JmsSendingMessageHandler messageHandler = new JmsSendingMessageHandler(jmsTemplate);
    messageHandler.setDestinationExpression(new FunctionExpression<Message<?>>(message -> {
        if(message.getHeaders().get("dest_type").equals("topic")){
               return destinationResolver.resolveDestinationName(null,(String) message.getHeaders().get("dest"),true);
            
        }else{
               return destinationResolver.resolveDestinationName(null,(String) message.getHeaders().get("dest"),false);
        }
    }));
    return messageHandler;
}

感谢所有输入，我将提出 GH 问题以在 DynamicJmsTemplate 中包含 pubsub 功能

Answer 1

我明白你的意思了。

它的逻辑是这样的：

protected Destination resolveDestinationName(Session session, String destinationName) throws JMSException {
    return getDestinationResolver().resolveDestinationName(session, destinationName, isPubSubDomain());
}

默认的DynamicDestinationResolver 是这样的：

if (pubSubDomain) {
        return resolveTopic(session, destinationName);
    }
    else {
        return resolveQueue(session, destinationName);
    }

作为一种解决方法，请考虑将您的destinationExpression 评估为javax.jms.Destination 实例，而不是它们的普通名称。这样您就不会被绑定到 pubSubDomain 属性。

还有一个 BeanFactoryDestinationResolver 用于将提供的名称解析为来自应用程序上下文的 Destination bean。

同时，我要求您提出一个 GH 问题，以将 pubSubDomain 支持添加到 DynamicJmsTemplate API 中。因此，您将能够根据JmsSendingMessageHandler 中的表达式评估来确定pubSubDomain。