Priority Messaging with SmallRye+Pulsar

[timoth...@yahoo.com]

Hey All,

Looking for some advise/feedback...

I have a requirement for my processes to pull messages from Pulsar based on Priority.  I know out-of-the-box Pulsar and thus SmallRye don't support that so looking for options.

1) Is it possible to extend SmallRye to override some of the behavior in the pulsar support to have it iterate and poll from multiple consumers (from high, med, low priority topics)?

2) I know I can setup multiple channels for each priority level, then internally pass the message onto an internal queue where I pull them off based on highest priority.  But ideally I wouldn't even pull them off the broker just to put them in essentially a waiting state in my JVM because that opens up some additional complexity.

3) Maybe I could introduce Starlight and SmallRye JMS since JMS does support message priorities.

4) Lastly I guess I exclude SmallRye altogether (or use it in a limited capacity) and implement my own custom solution.

Any thoughts would be much appreciated!