It doesnt dynamically prioritise based on expiration, but it does have a 'sorted queue' that can dynamically sort messages on the queue based on a string based property in the message that you could perhaps leverage to that end.
On Fri, 22 Nov 2024 at 06:02, Vinita Meka <vinita.m...@gmail.com> wrote: > > 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 --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org
