java – ActiveMQ：死信队列保持我的消息顺序

我使用ActiveMQ作为代理来传递消息.这些消息是用dabatase写的.有时,数据库无法访问或关闭.在这种情况下,我想回滚我的消息,以便稍后重试此消息,我想继续阅读其他消息.

这段代码工作正常,除了一点：回滚消息阻止我阅读其他代码：

private Connection getConnection() throws JMSException {
    RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
    redeliveryPolicy.setMaximumRedeliveries(3); // will retry 3 times to dequeue rollbacked messages
    redeliveryPolicy.setInitialRedeliveryDelay(5 *1000);  // will wait 5s to read that message

    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);
    Connection connection = connectionFactory.createConnection();
    ((ActiveMQConnection)connection).setUseAsyncSend(true);
    ((ActiveMQConnection)connection).setDispatchAsync(true);
    ((ActiveMQConnection)connection).setRedeliveryPolicy(redeliveryPolicy);
    ((ActiveMQConnection)connection).setStatsEnabled(true);
    connection.setClientID("myClientID");
    return connection;
}

我以这种方式创建会话：

session = connection.createSession(true,Session.SESSION_TRANSACTED);

回滚很容易问：

session.rollback();

假设我的队列中有3条消息：

1: ok
2: KO (will need to be treated again : the message I want to rollback)
3: ok
4: ok

我的消费者会做(线性序列)：

commit 1 
rollback 2
wait 5s
rollback 2
wait 5s
rollback 2
put 2 in dead letter queue (ActiveMQ.DLQ)
commit 3
commit 4

但我想要 ：

commit 1
rollback 2
commit 3
commit 4
wait 5s
rollback 2
wait 5s
rollback 2
wait 5s
put 2 in dead letter queue (ActiveMQ.DLQ)

那么,如何配置我的消费者以便以后延迟我的回滚消息呢？