tencent cloud

spring:
    application:
    name: application-name
    cloud:
    stream:
      rabbit:
        bindings:
          # Output channel name
          output:
            # Producer configuration information
            producer:
              # Type of the exchange used by the producer. If the exchange name already exists, this type must be the same as that of the exchange type
              exchangeType: direct
              # It is used to specify a routing key expression
              routing-key-expression: headers["routeTo"] # This field indicates that the `routeTo` field in the header is used as the routing key
              queueNameGroupOnly: true
          # Input channel name
          input:
            # Consumer configuration information
            consumer:
              # Type of the exchange used by the consumer. If the exchange name already exists, this type must be the same as that of the exchange type
              exchangeType: direct
              # Routing keys bound to the consumer message queue
              bindingRoutingKey: info,waring,error
              # The configuration will process the above routing keys
              bindingRoutingKeyDelimiter: ","  # This configuration item indicates that commas are used to separate the configured routing keys
              # Message acknowledgment mode. For more information, see `AcknowledgeMode`
              acknowledge-mode: manual
              queueNameGroupOnly: true
      bindings:
          # Output channel name
        output: # Channel name
          destination: direct_logs # Name of the exchange to be used
          content-type: application/json
          default-binder: dev-rabbit
        # Input channel name
        input: # Channel name
          destination: direct_logs # Name of the exchange to be used
          content-type: application/json
          default-binder: dev-rabbit
          group: route_queue1 # Name of the message queue to be used
      binders:
        dev-rabbit:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                host: amqp-xxx.rabbitmq.xxx.tencenttdmq.com #Cluster access address, which can be obtained by clicking “Access Address” in the “Operation” column on the cluster management page.
                port: 5672
                username: admin # Role name
                password: password # Role token
                virtual-host: vhostnanme # Vhost name

   public interface OutputMessageBinding {
     /**
        * Name of the channel to be used (output channel name)
        */
     String OUTPUT = "output";

     @Output(OUTPUT)
     MessageChannel output();
   }

   public interface InputMessageBinding {

     /**
        * Name of the channel to be used
        */
     String INPUT = "input";

     @Input(INPUT)
     SubscribableChannel input();
   }