在 bean 'container' 中发现不明确的工厂方法匹配

Question

我想在 Spring amqp 应用程序中实现多个队列侦听器。我试过这个：

    @Bean
    public SimpleMessageListenerContainer container(ConnectionFactory cf, DatabaseTransactionListener listener) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf);
        container.setQueueNames(QUEUE_DATABASE_TRANSACTION);
        container.setMessageListener(new MessageListenerAdapter(listener, "databaseTransaction"));
        container.setMessageConverter(new SerializerMessageConverter());
        return container;
    }

    @Component
    class DatabaseTransactionListener {

        public TransactionsBean databaseTransaction(TransactionsBean ro) {
            TransactionsBean obj = new TransactionsBean();
            System.out.println("!!!! Performing TransactionsBean processing !!!!");
            obj.setTransaction_id(" ??? some_id: " + ro.getMerchant_id());
            return obj;
        }
    }

    @Bean
    public SimpleMessageListenerContainer container(ConnectionFactory cf, ApiAttemptListener listener) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf);
        container.setQueueNames(QUEUE_DATABASE_API_ATTEMPT);
        container.setMessageListener(new MessageListenerAdapter(listener, "apiattemptTransaction"));
        container.setMessageConverter(new SerializerMessageConverter());
        return container;
    }

    @Component
    class ApiAttemptListener {

        public ApiAttemptsBean apiattemptTransaction(ApiAttemptsBean ro) {
            ApiAttemptsBean obj = new ApiAttemptsBean();
            System.out.println("!!!! Performing ApiAttempts processing !!!!");
            obj.setMerchant_id(454545);
            return obj;
        }
    }

我在启动时遇到错误：Error creating bean with name 'container' defined in org.database.context.ContextServer: Ambiguous factory method matches found in bean 'container'

实现多个侦听器以处理多个队列的正确方法是什么？

Answer 1

Bean 名称和 Bean 工厂方法名称必须是唯一的；使用 @Bean 时，默认的 bean 名称是方法名称。

为 bean 工厂方法指定唯一名称 container1()、container2()。

在 bean 'container' 中发现不明确的工厂方法匹配

Ambiguous factory method matches found in bean 'container'

java

spring

spring-amqp