使用Spring Rabbitmq Stomp的持久队列

Question

我对Spring和RabbitMQ有以下配置：

    @Bean
    public TopicExchange streamingExchange(@Qualifier("admin") final RabbitAdmin rabbitAdmin) {
        TopicExchange topicExchange = new TopicExchange(exchangeName, true, false);
        topicExchange.setAdminsThatShouldDeclare(rabbitAdmin);
        return topicExchange;
    }

    @Override
    public void configureMessageBroker(final MessageBrokerRegistry config) {
        config.enableStompBrokerRelay("/my_stream", "/test").setRelayHost(host)
        .setSystemLogin(username).setSystemPasscode(password).setClientLogin(username)
                .setClientPasscode(password);
    }

    @Override
    public void registerStompEndpoints(final StompEndpointRegistry registry) {
        registry.addEndpoint("/test").setAllowedOrigins("*").withSockJS();
    }

为了防止这种情况，我想创建持久队列（因为这些队列的持久度设置为false，自动删除设置为true）。如果不是，我想在这些队列上设置一些过期时间（例如，1小时或其他时间）。从RabbitMQ文档来看，我们似乎可以在头中传递这些值，但是，这只适用于版本3.6.0以后的版本，因为我们有3.5.4，它不是一个选项。

有没有其他方法可以配置它？（另一种方法是为connect请求添加某种侦听器，并以编程方式配置队列参数？我不确定这是否可行，因为我不太了解spring rabbitmq stomp插件）

Answer 1

想知道您是否尝试过使用rabbitmqadmin工具将队列声明为持久队列？

rabbitmqadmin declare queue name=your-queue durable=true

管理工具可从以下网址下载https://www.rabbitmq.com/management-cli.html