spring:
  rabbitmq:
      # The host address can be obtained in the console, or use the RabbitMQ service address.
    host: 1.14.235.155
    port: 5672
    # The name of the role to be used can be obtained from the role management console.
    username: admin
    # Role token.
    password: eyJrZXlJZ....
    # The full name of the vhost can be obtained from the vhost tab in the cluster console.
    virtual-host: test_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() {
        // The dead letter queue can be bound in this way.
        Map<String, Object> requestParam = new HashMap<>();
        requestParam.put("x-dead-letter-exchange", "my-deadLetter-exchange");
        // Set the message expiration 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());
    }
}