如何在spring中设置DefaultMessageListenerContainer中的持久订户?

消息的生产者没有将消息作为持久消息发送,当我试图通过MessageListener使用消息时,如果发生任何异常(运行时),它将重试特定次数(默认为AMQ端的6次)并且消息将丢失。

我的代码是这样的:-

@Configuration
@PropertySource("classpath:application.properties")
public class ActiveMqJmsConfig {

@Autowired
private AbcMessageListener abcMessageListener;

public DefaultMessageListenerContainer purchaseMsgListenerforAMQ(
    @Qualifier("AMQConnectionFactory") ConnectionFactory amqConFactory) {

    LOG.info("Message listener for purchases from AMQ : Starting");
    DefaultMessageListenerContainer defaultMessageListenerContainer =
        new DefaultMessageListenerContainer();

    defaultMessageListenerContainer.setConnectionFactory(amqConFactory);

    defaultMessageListenerContainer.setMaxConcurrentConsumers(4);

    defaultMessageListenerContainer
        .setDestinationName(purchaseReceivingQueueName);

    defaultMessageListenerContainer
        .setMessageListener(abcMessageListener);

    defaultMessageListenerContainer.setSessionTransacted(true);

    return defaultMessageListenerContainer;
}

 @Bean
@Qualifier(value = "AMQConnectionFactory")
public ConnectionFactory activeMQConnectionFactory() {

    ActiveMQConnectionFactory amqConnectionFactory =
        new ActiveMQConnectionFactory();

    amqConnectionFactory
        .setBrokerURL(System.getProperty(tcp://localhost:61616));
    amqConnectionFactory
        .setUserName(System.getProperty(admin));
    amqConnectionFactory
        .setPassword(System.getProperty(admin));

    return amqConnectionFactory;

}

}

@Component
public class AbcMessageListener implements MessageListener {
 @Override
public void onMessage(Message msg) {
//CODE implementation
}

}

问题:-通过在连接级别(connection.setclientid(“String”)设置客户端id,即使消息不是持久的,我们也可以订阅为持久订户。通过这样做,如果应用程序抛出运行时异常,在一定次数的重试尝试之后,将为队列创建DLQ,并将消息移动到DLQ。

但在DefaultMessageListenerContainer中,连接不向客户端公开。我想它是由类本身作为一个池来维护的。