Hi Qpid Users,

I have a use case where I need to ensure SLA guarantees based on dequeue
latency for different message class. Each message has a specific
time-to-live (TTL), and must be dequeued before it expires to meet its SLA.

While I’m aware that Qpid Broker-J supports priority queues, the priorities
in this case are static and don’t directly help with the dynamic nature of
my use case, where the expiration time for each message is different. The
challenge is to ensure that messages are dequeued before their TTL expires,
based on their urgency (i.e., how close they are to their expiration time).

Could you suggest an approach or a mechanism within Qpid Broker-J to
achieve the following:

1. Dynamically prioritize messages based on how close they are to their
expiration time, so that messages nearing expiration are dequeued first.
2. Ensure messages are dequeued within the SLA window, before their TTL
expires.
3. Handle the scenario where ongoing inserts with different TTLs are
continuously added to the queue, and ensure that the system adjusts
dynamically to the varying expiration times.

Are there any features or strategies in Qpid Broker-J that would help in
implementing this dynamic priority system, considering the TTL-based
expiration for messages?

Regards,
Vinita Meka

Reply via email to