Issue with subscribeAsMessages Method in Quarkus Redis Client about quarkus

[otavioprado]

@cescoffier

Sure, here is the repository with the reproducer: https://github.com/otavioprado/issue-subscribe-asmessages-reproducer

In the repository, the subscribeToChannelsWorks implementation works correctly, while the subscribeToChannelsNonWorking implementation does not. The subscribeToChannelsNonWorking method uses subscribeAsMessages, but the processMessage method is never called when events are received on the channels.

You can switch between the working and non-working implementations in the MainService class by simply uncommenting the one you want to use:

void onStart(@Observes StartupEvent ev) {
    LOG.info("MainService is starting");
    reproducer.subscribeToChannelsNonWorking();
    //reproducer.subscribeToChannelsWorks();
}

Thank you for your help!

[cescoffier]

Oh gosh, this is embarrassing...

Thanks for the reproducer, I found the issue, adding a test and opening a PR...

[quarkus-bot]

/cc @Ladicek (redis), @cescoffier (redis), @machi1990 (redis)

[cescoffier]

Do you have a reproducer? We have test covering this features, I would like to see what is not tested on our side.