activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt Lachman <matthew.j.lach...@gmail.com>
Subject Queue messages not dequeuing
Date Wed, 22 Feb 2012 16:19:50 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message