Hi, I'm currently having a problem with messages sent to a queue that aren't being dequeued. It appears that my listener is receiving the messages but they are stuck "in flight" on the server and are never being dequeued.
My problem domain: I've set up a semaphore of sorts where I have one listener assigned to the queue. If a message comes in with an identifier (defined by my code) that is already being processed, that message is held by my listener in a Map<Id, LinkedList<Object>>. The message contains a serialized object which is what is stored in the LinkedList. Once my listener gets notification (via a Topic) that the in-progress item is complete, the next object for the id is pulled from the Map. In this way, I can assure that only one message is being processed at a time for a given identifier. My environment: I'm running my app in JBoss 4.2.2, Java 1.6 with an ActiveMQ 5.6 snapshot (was running into this problem on 5.5: https://issues.apache.org/jira/browse/AMQ-3465). It's all local on my Win 7 x64 machine. I'm using Session.AUTO_ACKNOWLEDGE and non-persistent messaging. Any ideas? Has anyone else run into this? Thanks, Matt
