I've started to work on adding some basic pubsub support for Micronaut-ignite. I only have a draft PR in progress. There are a couple modules that already implement pub-sub so those modules would be a good start for reference: https://github.com/micronaut-projects/micronaut-gcp https://github.com/micronaut-projects/micronaut-kafka https://github.com/micronaut-projects/micronaut-mqtt
https://github.com/micronaut-projects/micronaut-ignite/pull/62
