RabbitListener processAmqpListener no such bean error

[caozhiyuan]

if none producer (not autowired ConnectionFactoryContextWrapper ), only consumer will raise error (RabbitListener processAmqpListener no such bean) , please before super.processAmqpListener get ConnectionFactory bean.

[rwanderc]

@caozhiyuan could you give more details what is the problem?
I didn't understand which kind of error the consumer will raise, or which bean is supposedly missing. Having only RabbitListener should be a total fine use case.
An example repository showcasing the error would also help clearing things up.

[caozhiyuan]

at this demo ( https://github.com/freenowtech/spring-multirabbit/tree/release/2.2/spring-multirabbit-examples/spring-multirabbit-example-java/src/main/java/com/mytaxi/spring/multirabbit/example ) remove SomeController.java and remove first RabbitListener and run app . @rwanderc

package com.mytaxi.spring.multirabbit.example;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
class SomeListeners
{

    private static final Logger LOG = LoggerFactory.getLogger(SomeListeners.class);

    private static final String SAMPLE_EXCHANGE = "sampleExchange";
    private static final String SAMPLE_ROUTING_KEY = "sampleRoutingKey";
    private static final String SAMPLE_QUEUE = "sampleQueue";

    private static final String SAMPLE_EXCHANGE_A = SAMPLE_EXCHANGE + "A";
    private static final String SAMPLE_ROUTING_KEY_A = SAMPLE_ROUTING_KEY + "A";
    private static final String SAMPLE_QUEUE_A = SAMPLE_QUEUE + "A";

    private static final String SAMPLE_EXCHANGE_B = SAMPLE_EXCHANGE + "B";
    private static final String SAMPLE_ROUTING_KEY_B = SAMPLE_ROUTING_KEY + "B";
    private static final String SAMPLE_QUEUE_B = SAMPLE_QUEUE + "B";


    /**
     * Second listener, listening to the specific context 'connectionNameA', which is provided from the configuration 'spring.multirabbitmq.connectionNameA'.
     *
     * @param message the message received.
     */
    @RabbitListener(containerFactory = "connectionNameA",
        bindings = @QueueBinding(
            value = @Queue(SAMPLE_QUEUE_A),
            exchange = @Exchange(SAMPLE_EXCHANGE_A),
            key = SAMPLE_ROUTING_KEY_A))
    void listenConnectionNameA(String message)
    {
        LOG.info("Listener 'connectionNameA': {}", message);
    }


    /**
     * Third listener, listening to the specific context 'connectionNameB', which is provided from the configuration 'spring.multirabbitmq.connectionNameB'.
     *
     * @param message the message received.
     */
    @RabbitListener(containerFactory = "connectionNameB",
        bindings = @QueueBinding(
            value = @Queue(SAMPLE_QUEUE_B),
            exchange = @Exchange(SAMPLE_EXCHANGE_B),
            key = SAMPLE_ROUTING_KEY_B))
    public void listenConnectionNameB(String message)
    {
        LOG.info("Listener 'connectionNameB': {}", message);
    }

}

2020-02-26 08:29:02.656 INFO 17364 --- [ main] c.m.s.multirabbit.example.Application : Starting Application on caozhiyuan with PID 17364 (D:\Code\spring-multirabbit\spring-multirabbit-examples\spring-multirabbit-example-java\target\classes started by Administrator in D:\Code\spring-multirabbit)
2020-02-26 08:29:02.711 INFO 17364 --- [ main] c.m.s.multirabbit.example.Application : No active profile set, falling back to default profiles: default
2020-02-26 08:29:07.196 INFO 17364 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8080 (http)
2020-02-26 08:29:07.224 INFO 17364 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2020-02-26 08:29:07.225 INFO 17364 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.27]
2020-02-26 08:29:07.424 INFO 17364 --- [ main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2020-02-26 08:29:07.424 INFO 17364 --- [ main] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 4433 ms
2020-02-26 08:29:07.705 WARN 17364 --- [ main] ConfigServletWebServerApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'someListeners' defined in file [D:\Code\spring-multirabbit\spring-multirabbit-examples\spring-multirabbit-example-java\target\classes\com\mytaxi\spring\multirabbit\example\SomeListeners.class]: Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanInitializationException: Could not register rabbit listener endpoint on [void com.mytaxi.spring.multirabbit.example.SomeListeners.listenConnectionNameA(java.lang.String)] for bean someListeners, no RabbitListenerContainerFactory with id 'connectionNameA' was found in the application context; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'connectionNameA' available
2020-02-26 08:29:07.729 INFO 17364 --- [ main] o.apache.catalina.core.StandardService : Stopping service [Tomcat]
2020-02-26 08:29:07.810 INFO 17364 --- [ main] ConditionEvaluationReportLoggingListener :

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-02-26 08:29:08.087 ERROR 17364 --- [ main] o.s.b.d.LoggingFailureAnalysisReporter :

---

APPLICATION FAILED TO START

---

Description:

A component required a bean named 'connectionNameA' that could not be found.

Action:

Consider defining a bean named 'connectionNameA' in your configuration.

[rwanderc]

thanks @caozhiyuan, I will look into it and update the thread