4.2.12、自定义队列和主题

Spring Cloud Stream 给 RabbitMQ consumer 绑定已存在的队列

首先已经使用 RabbitMQ Web UI创建了一个主题交换TX，并绑定到交换两个队列TX.Q1和TX.Q2，每个队列分别与路由键rk1和rk2绑定，并向交换产生了一些消息。

现在，我想使用Spring Cloud Stream创建一个使用者，该使用者将仅从Q1获取消息。

配置：

spring:
  cloud:
    stream:
      bindings:
        input:
          binder: <binder_name>
          destination: TX
          group: Q1
      binders:
        defaultRabbit:
          type: rabbit
        <binder_name>:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                host: <host>
                port: <port>
                virtual-host: <vhost>
                username: <username>
                password: <password>
      rabbit:
        bindings:
          input:
            consumer:
              binding-routing-key: rk1
              exchange-name: TX
              queue-name-group-only: true
              bind-queue: true
              exchange-durable: true
              exchange-type: topic