tencent cloud

spring:
  rabbitmq:
      # The host address can be obtained in the console. You can also use the RabbitMQ service address
    host: amqp-xx.rabbitmq.x.tencenttdmq.com
    port: 5672
    # Name of the role to be used, which can be obtained on the **Role Management** page in the console
    username: admin
    # Role token
    password: eyJrZXlJZ....
    # Full name of vhost, which can be obtained on the **Vhost** tab in the console
    virtual-host: amqp-xxx|Vhost

/**
 * Fanout exchange configuration
 */
@Configuration
public class FanoutRabbitConfig {

    /**
     * Exchange
     */
    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange("fanout-logs", true, false);
    }


    /**
     * Message queue
     */
    @Bean
    public Queue fanoutQueueA() {
        return new Queue("ps_queue", true);
    }

    @Bean
    public Queue fanoutQueueB() {
        // You can use this method to bind a dead letter queue
        Map<String, Object> requestParam = new HashMap<>();
        requestParam.put("x-dead-letter-exchange", "my-deadLetter-exchange");
        // Set the message validity period
        requestParam.put("x-message-ttl", 60000);
        return new Queue("ps_queue1", true, false,true, requestParam);
    }

    /**
     * Bind the message queue to the exchange
     */
    @Bean
    public Binding bindingFanoutA() {
        return BindingBuilder.bind(fanoutQueueA())
                .to(fanoutExchange());
    }

    @Bean
    public Binding bindingFanoutB() {
        return BindingBuilder.bind(fanoutQueueB())
                .to(fanoutExchange());
    }
}