grails - Grails 3.3.2 と rabbitmq-native プラグイン (3.4.4) を使用すると、prefetch=1 の単一のコンシューマーが例外の発生後にメッセージの消費を停止します

Question

true に設定するように再試行しました。私の理解では、メッセージは消費者に何度も何度も継続的に届けられるべきです。代わりに、再キューイングされたメッセージや新しいメッセージを消費せずに、そこに留まります。私は com.budjb と com.rabbitmq と org.springframework.amqp のログを TRACE まで上げましたが、切断が起こっているのが見えません... Heeelppp

アプリケーション.groovy

rabbitmq {
uri = new URI(System.env.CLOUDAMQP_URL ?: "amqp://test:test@localhost/test")
username = uri.userInfo.split(":")[0]
password = uri.userInfo.split(":")[1]

connections = [
        [name              : 'main',
         host              : uri.host,
         port              : 5672,
         username          : username,
         requestedHeartbeat: 10,
         automaticReconnect: true,
         virtualHost       : uri.path.substring(1),   //remove leading slash
         password          : password]
]

queues = [[name: com.coco.jms.RabbitQueues.INDEX_TRANSACTION.destinationName, autoDelete: false, durable: true, exclusive: false]]

消費者：

class IndexTransactionConsumer implements MessageConsumerEventHandler {

static rabbitConfig = [
        connection: 'main',
        consumers : 1,
        queue     : Boolean.valueOf((String) System.getProperty("is_amqp_consumer")) ? RabbitQueues.INDEX_TRANSACTION.destinationName : null,
        transacted: true,
        autoAck   : AutoAck.POST,
        retry     : true
]

def handleMessage(Map body, MessageContext messageContext) {
    log.info("RABBITMQ - *CONSUME* Received event to index transaction (Map). " + body)

    throw new Exception("Force fail")
}
....
}

UPDATE は、transacted=true および autoAck = AutoAck.POST のときに AbstractConsumerContext.groovy 内で起動する txRollback() が、basicReject nack が RabbitMQ サーバーに到達するのを阻止しているようです。

if (configuration.getTransacted()) {
    context.getChannel().txRollback()
}

if (configuration.getAutoAck() == AutoAck.POST) {
            context.getChannel().basicReject(context.getEnvelope().deliveryTag, configuration.getRetry())
}