我需要为ActiveMQ创建一个主题和一个持久订阅者，我的问题是我不知道在哪里指定。我可以创建主题并使用消息，但是当我关闭订阅服务器然后继续发送消息并再次打开订阅服务器时，它将无法读取它们。

这是我到目前为止的内容：

发送消息：

    JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);
    jmsTemplate.setPubSubDomain(true);
    jmsTemplate.setDeliveryMode(DeliveryMode.PERSISTENT);
    jmsTemplate.setDeliveryPersistent(true);
    jmsTemplate.convertAndSend("venta.topic",venta);

收到消息：

@JmsListener(destination = "venta.topic",id = "comercial",subscription = "venta.topic")
public void receiveMessage(Venta venta) {
    logger.log(Level.INFO, "RECEIVED : {0}",venta);      
    repository.save(venta);
}

我已经阅读了这篇文章，并且我了解我需要创建持久订阅者。

我还阅读了Spring文档

而且我认为这与DefaultJmsListenerContainerFactory（我没有实现，我使用的是默认配置）有关，文档显示：

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory =
            new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory());
    factory.setDestinationResolver(destinationResolver());
    factory.setConcurrency("3-10");
    return factory;
}

但是我似乎找不到在哪里创建持久会话。生产者和订户都连接到独立的activemq二进制文件。

希望您能帮助我，在此先感谢。