From users-return-30293-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Thu Feb 23 14:41:37 2012 Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 964219D33 for ; Thu, 23 Feb 2012 14:41:37 +0000 (UTC) Received: (qmail 29724 invoked by uid 500); 23 Feb 2012 14:41:37 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 29665 invoked by uid 500); 23 Feb 2012 14:41:36 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 29653 invoked by uid 99); 23 Feb 2012 14:41:36 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Feb 2012 14:41:36 +0000 X-ASF-Spam-Status: No, hits=2.0 required=5.0 tests=SPF_NEUTRAL,URI_HEX X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: 216.139.236.26 is neither permitted nor denied by domain of jakub.korab@gmail.com) Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Feb 2012 14:41:29 +0000 Received: from joe.nabble.com ([192.168.236.139]) by sam.nabble.com with esmtp (Exim 4.72) (envelope-from ) id 1S0Zr3-0005gg-4L for users@activemq.apache.org; Thu, 23 Feb 2012 06:41:09 -0800 Date: Thu, 23 Feb 2012 06:41:09 -0800 (PST) From: Jakub Korab To: users@activemq.apache.org Message-ID: <1330008069122-4414032.post@n4.nabble.com> In-Reply-To: References: Subject: Re: Queue messages not dequeuing MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Hi Matt, When you say that the message is not being dequeued, do you mean from the queue on the broker? The overall scheme itself seems to be pretty complicated; where are the topic messages coming from? If you are trying to ensure that messages for a particular id are consumed in sequence then perhaps message groups (http://activemq.apache.org/message-groups.html) might fit the bill better and simplify your code. Jakub Matt Lachman wrote > > 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 > -- View this message in context: http://activemq.2283324.n4.nabble.com/Queue-messages-not-dequeuing-tp4410892p4414032.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.