Multiqueue RabbitListener с помощью spel

Question

Я начинаю с RabbitMQ. Я создал проект Spring Boot с Maven, и я использую зависимости Spring, чтобы заставить все работать, однако, попробовав слушателей, вытесняющих имена очередей и пытающихся сделать это " multiqueue»через аннотацию:

@RabbitListener(containerFactory = "rabbitListenerContainerFactory", queues = {"#{'${my.property.containing.the.queues}'.split(',')}"}) 

И, как указано в документации весной AMQP

начиная с версии 1.5, вы можете экстернализовать имена очередей, используя свойство placeh olders и SPEL:

@Component public class MyService { 

@RabbitListener(queues = "#{'${property.with.comma.delimited.queue.names}'.split(',')}") 
    public void processOrder(String data, @Header(AmqpHeaders.CONSUMER_QUEUE) String queue) { 
     ... 
} 

Я просто и ошибки со следующим StackTrace:

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'myListenerBean' defined in file [F:\workspace\MyProject\target\classes\co\com\listener\MyListenerClass.class]: Initialization of bean failed; nested exception is java.lang.IllegalArgumentException: @RabbitListener can't resolve '[Ljava.lang.String;@4d18b73a' as either a String or a Queue 
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:547) 
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476) 
    at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:303) 
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) 
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299) 
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194) 
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:755) 
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:762) 
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) 
    at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118) 
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:690) 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:322) 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:970) 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:959) 
    at co.com.ExtendedAppConfig.main(ExtendedAppConfig.java:23) 
Caused by: java.lang.IllegalArgumentException: @RabbitListener can't resolve '[Ljava.lang.String;@4d18b73a' as either a String or a Queue 
    at org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor.resolveQueues(RabbitListenerAnnotationBeanPostProcessor.java:307) 
    at org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor.processAmqpListener(RabbitListenerAnnotationBeanPostProcessor.java:242) 
    at org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor$1.doWith(RabbitListenerAnnotationBeanPostProcessor.java:210) 
    at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:493) 
    at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:473) 
    at org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor.postProcessAfterInitialization(RabbitListenerAnnotationBeanPostProcessor.java:205) 
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsAfterInitialization(AbstractAutowireCapableBeanFactory.java:422) 
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1577) 
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:539) 
    ... 14 common frames omitted 

Мой pom.xml является следующее:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
    <modelVersion>4.0.0</modelVersion> 
    <groupId>Organization-RabbitMQ</groupId> 
    <artifactId>Extended-Orchestrator</artifactId> 
    <version>0.0.1-SNAPSHOT</version> 

    <parent> 
     <groupId>org.springframework.boot</groupId> 
     <artifactId>spring-boot-starter-parent</artifactId> 
     <version>1.3.5.RELEASE</version> 
    </parent> 
    <dependencies> 
     <!-- Dependency to another project --> 
     <dependency> 
      <groupId>Organization-RabbitMQ</groupId> 
      <artifactId>Generic-Orchestrator</artifactId> 
      <version>0.0.1-SNAPSHOT</version> 
      <scope>compile</scope> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-web</artifactId> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-amqp</artifactId> 
      <version>1.3.4.RELEASE</version> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-jersey</artifactId> 
     </dependency> 
    </dependencies> 

    <build> 
     <plugins> 
      <plugin> 
       <groupId>org.springframework.boot</groupId> 
       <artifactId>spring-boot-maven-plugin</artifactId> 
       <version>1.3.2.RELEASE</version> 
       <executions> 
        <execution> 
         <goals> 
          <goal>repackage</goal> 
         </goals> 
        </execution> 
       </executions> 
      </plugin> 
     </plugins> 
    </build> 

    <repositories> 
     <repository> 
      <id>spring-milestone</id> 
      <url>https://repo.spring.io/libs-release</url> 
     </repository> 
     <repository> 
      <id>spring-releases</id> 
      <url>https://repo.spring.io/libs-release</url> 
     </repository> 
    </repositories> 
    <pluginRepositories> 
     <pluginRepository> 
      <id>spring-milestone</id> 
      <url>https://repo.spring.io/libs-release</url> 
     </pluginRepository> 
     <pluginRepository> 
      <id>spring-releases</id> 
      <url>https://repo.spring.io/libs-release</url> 
     </pluginRepository> 
    </pluginRepositories> 

</project> 

Я m Я чего-то не хватает? заранее спасибо

Answer 1

Это определенно было введено в 1.5 GA: https://jira.spring.io/browse/AMQP-533.

Похоже, ваша spring-rabbit зависимость в 1.4.x версии еще как-то: https://github.com/spring-projects/spring-amqp/blob/1.4.x/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/annotation/RabbitListenerAnnotationBeanPostProcessor.java#L307

Try обеспечить

<spring-amqp.version>1.5.6.RELEASE</spring-amqp.version> 

недвижимость в вашем ПОМ. Или еще лучше попытайтесь понять через mvn dependency:tree -Dverbose, который вытаскивает неправильную версию для вас и исправляет этот конфликт.

Answer 2

Если вы используете имя очереди в системной переменной, и нужно настроить значение имени с условными, вы можете использовать Spel:

@RabbitListener(queues = "#{'${cluster.name}' != null?'batch.queue-${cluster.name}':'batch.queue'}", containerFactory = "listenerContainerFactory")