我的应用程序当前使用IBM MQ，并且具有队列配置设置，并且可以与JMS正常工作。例如

@EnableJms
@Configuration
public class IBmqueueConfig {

    @Bean("defaultContainer")
    public JmsListenerContainerFactory containerFactory(final ConnectionFactory connectionFactory,final ErrorHandler errorHandler) {
        final DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setErrorHandler(errorHandler);
        return factory;
    }
}

我可以收到如下消息并进行处理：

@Service
public class ProcessMessageReceive {

    @JmsListener(destination = "${queue}",concurrency = "${threads}",containerFactory = "defaultContainer")
    public Message processMessage(@Payload final String message) {
        //do stuff
    }
}

我需要使用RabbitMQ进行测试，并且需要其他配置。我有以下课程：

@Configuration
@ConfigurationProperties(prefix = "spring.rabbitmq")
@EnableRabbit
public class RabbitMQConfiguration {

    private String host;
    private int port;
    private String username;
    private String password;
    private String virtualHost;


    @Bean
    public DirectExchange exchange() {
        return new DirectExchange(exchange);
    }


    @Bean("defaultContainer")
    public JmsListenerContainerFactory containerFactory(@Qualifier("rabbit-connection-factory") final ConnectionFactory connectionFactory) {
        final DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(); //ERROR
        return factory;
    }


    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(@Qualifier("rabbit-connection-factory") final ConnectionFactory connectionFactory,@Value("spring.rabbitmq.listener.simple.concurrency") final int concurrency,@Value("spring.rabbitmq.listener.simple.max-concurrency") final int maxConcurrency) {
        final SimpleRabbitListenerContainerFactory containerFactory = new SimpleRabbitListenerContainerFactory();
        containerFactory.setConnectionFactory(connectionFactory);
        containerFactory.setConcurrentConsumers(concurrency);
        containerFactory.setMaxConcurrentConsumers(maxConcurrency);
        containerFactory.setDefaultRequeueRejected(false);

        return containerFactory;
    }

    @Bean(name = "rabbit-connection-factory")
    public ConnectionFactory connectionFactory() {
        final CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setusername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(virtualHost);
        return connectionFactory;
    }

    @Bean
    public Queue inboundQueue() {
        return new Queue(fixInboundQueue,true);
    }

    @Bean
    public Binding inboundQueueBinding() {
        return bind(inboundQueue())
                .to(exchange())
                .with(routingKey);
    }
}

我在第factory.setConnectionFactory(connectionFactory);行遇到错误，因为它期望javax.jms.ConnectionFactory但提供了Rabbit MQ One。

有没有一种方法可以连接Rabbit MQ ConnectionFactory？我知道是否可以使用RMQConnectionFactory，但是我正在寻找是否可以通过Spring Rabbit依赖关系实现。

目标是避免专门为Rabbit MQ写另一个processMessage()并重用我已有的东西。

或者，我可以同时使用两个注释吗？在哪种情况下，我会根据生产或测试使用弹簧轮廓来启用所需的弹簧轮廓？

  @RabbitListener(queues = "${app.rabbitmq.queue}") 
  @JmsListener(destination = "${queue}",containerFactory = "defaultContainer")
    public Message processMessage(@Payload final String message) {
        //do stuff
    }