Java连接MQ集群

    @Bean
    public Queue quorumQueue(){
        return QueueBuilder.durable("cluster.quorum.queue")
                .quorum()
                .build();
    }