如何删除 ActiveMQ 中的非活动目的地？

Question

我需要配置 activemq 来删除非活动队列：

如下使用 websocket 进行配置

@Configuration
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

      @Override
        public void configureMessageBroker(MessageBrokerRegistry config) {


          config.setApplicationDestinationPrefixes("/app")
            .setUserDestinationPrefix("/user")
            .enableStompBrokerRelay("/topic","/queue","/user")
            .setRelayHost("localhost")
            .setRelayPort(61613);


        }


        public void registerStompEndpoints(StompEndpointRegistry registry) {
            registry.addEndpoint("/websocket").withSockJS();
        }


}

如何在 spring boot 中添加以下destinationPolicy？这部分如何导入？

  <destinationPolicy>
     <policyMap>
        <policyEntries>
           <policyEntry queue=">" gcInactiveDestinations="true" inactiveTimoutBeforeGC="30000"/>
        </policyEntries>
     </policyMap>
  </destinationPolicy>

</broker>

Answer 1

将此 bean 定义添加到您的配置中

@Bean
public BrokerService broker() throws Exception {
    BrokerService broker = new BrokerService();
    broker.setSchedulePeriodForDestinationPurge(10000);
    broker.addConnector("stomp://localhost:61613");
    PolicyMap policyMap = new PolicyMap();
    PolicyEntry policyEntry = new PolicyEntry();
    policyEntry.setGcInactiveDestinations(true);
    policyEntry.setInactiveTimeoutBeforeGC(30000);
    policyEntry.setQueue(">");
    List<PolicyEntry> entries = new ArrayList<PolicyEntry>();
    entries.add(policyEntry);
    policyMap.setPolicyEntries(entries);
    broker.setDestinationPolicy(policyMap);
    return broker;
}

并验证您是否拥有这些依赖项

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-stomp</artifactId>
</dependency>