Graceful shutdown when use RabbitMessagePublisher

[ishea]

I have some service that send message to RabbitMQ after database transaction commit.

When the application stops while the transaction commit RabbitMessagePublisher.send throw java.lang.IllegalStateException: connection '8c9ff08f-e48f-4b14-bf6d-d159d4d8c3d0' is not active.

I think this behavior is related to the initialization of the plugin. Plugin load after database layer (domain classes) and destroy before database layer.

Maybe changing the plugin initialization order will solve this problem?

I use 3.1.3 plugin version and grails 2.5.6

[jaGarcia]

Has there been any traction on this issue or still being experienced? Think it may be stinging me.

[eugishch]

Yes, I solved the problem.

At RabbitmqNativeBootStrap.destroy, I wait for all database connections to close and then destroy rabbit context

Example:

def destroy = {

    int maxAttempts = 100

    Executors.newSingleThreadExecutor().execute {
        int currentAttempts = 0

        while (currentAttempts <= maxAttempts && isDatabaseConnectionActive()) {
            currentAttempts++
            sleep(300)
        }

        destroyRabbitmqContext()
    }
}

private boolean isDatabaseConnectionActive() {

    try {
        return dataSourceUnproxied.getActive() > 1
    } catch (e) {
        return false
    }
}

[jaGarcia]

Did you, or anyone else, find a solution to this version 4 of the plugin?