I am currently writing a distributed system using hazelcast. I have a few questions regarding Queues implemented using hazelcast.
- What is the best way to process data from the Queue? I currently have threads on each "node" reading off the blocking queue processing the data. Is this correct or is there some class I am not aware of that takes care of this like JMS or messageListener?
- I see there is a time-to-live-seconds setting which will remove the entry from the Queue once expired. My question is... is there any way to detect the removal of an expired item from the Queue? I know there are Listeners but this does not help as this is fired on all the "nodes" and not just one. I am looking for a way of executing code for each expired message (similar to a dead letter queue).
Any input or advice on this matter would be greatly appreciated.
Thanks