Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 68653 invoked from network); 25 Aug 2009 11:50:11 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 25 Aug 2009 11:50:11 -0000 Received: (qmail 21059 invoked by uid 500); 25 Aug 2009 11:50:36 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 20996 invoked by uid 500); 25 Aug 2009 11:50: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 20986 invoked by uid 99); 25 Aug 2009 11:50:36 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Aug 2009 11:50:36 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of gary.tully@gmail.com designates 72.14.220.154 as permitted sender) Received: from [72.14.220.154] (HELO fg-out-1718.google.com) (72.14.220.154) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 25 Aug 2009 11:50:26 +0000 Received: by fg-out-1718.google.com with SMTP id 13so661587fge.21 for ; Tue, 25 Aug 2009 04:50:04 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:message-id:subject:from:to:content-type; bh=AEEOVGm60WPA6paLi+WiHf91AR0JJrHcmZfWQTthex0=; b=hcvBok60/4Ls0UW2cMTVX71EGmIfjqbTjeOdgsMxlp08nm3ejc1R3gPQulBU1OI/3n l8SNbGbi2jTqcQ7Hks0vXvyLwbIFIkf4TFOJE8PCadZB0k0ywdsK3ISCFmHrA79HCLfA 5T0kCujOqkPRtHdtt/HJjYESioy2DW+dSbgPM= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=jZRyOAEfHqWMhLvjNl88j8fd6iAZiyPvF419thN8vSPK6ZHwRcJhIedzgrEX0eYUqh vOzRbTBnmyRjFsTBMKAqcaRk0d7HQkytTBwqJaMA7SVdegL87qNpOVrFskRu3oqeWWhS Is0zwPOYbXOQJR15RRdUZgJClVk2sXbNCDN+w= MIME-Version: 1.0 Received: by 10.86.227.1 with SMTP id z1mr4136962fgg.56.1251201004376; Tue, 25 Aug 2009 04:50:04 -0700 (PDT) In-Reply-To: <25132261.post@talk.nabble.com> References: <25132261.post@talk.nabble.com> Date: Tue, 25 Aug 2009 12:50:04 +0100 Message-ID: <3a73c17c0908250450n72de2ae6yb66f269a6796238d@mail.gmail.com> Subject: Re: Sender/Receiver hangs after 4776 messages .... From: Gary Tully To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=001485ea0ff468938f0471f5ef9d X-Virus-Checked: Checked by ClamAV on apache.org --001485ea0ff468938f0471f5ef9d Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit You have a transacted session in your consumer but you do not commit any transactions so the broker is holding messages in memory pending a commit and the memory limits are preventing further message production because of producer flow controll. You should see some relevant details in the jmx console. To resolve, change: QueueSession session = qconn.createQueueSession(true, 0); to: QueueSession session = qconn.createQueueSession(false, AUTO_ACKNOWLEDGE); 2009/8/25 Kartick Suriamoorthy @ zp > > > I am just trying out ActiveMQ and I seem to be running into a problem. > > I have not changed the initial configuration in any way. I just bring up > the > ActiveMQ server, create a queue called ks-test-queue via the admin page. > > Then I create a jndi.properties file (attached), and start a sender and a > receiver. The sender spawns 10 threads and each thread send 1000 messages > to > the ks-test-queue. The receiver just listens on the ks-test-queue. > > After the sender sends 4776 messages, no more messages are being sent or > received. I see no exceptions anywhere (in the console of ActiveMQ or in my > sender/receiver programs). > > Any idea what is going on ? > > http://www.nabble.com/file/p25132261/jndi.properties jndi.properties > > http://www.nabble.com/file/p25132261/MessageSender.java MessageSender.java > > http://www.nabble.com/file/p25132261/MessageReceiver.java > MessageReceiver.java > -- > View this message in context: > http://www.nabble.com/Sender-Receiver-hangs-after-4776-messages-....-tp25132261p25132261.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- http://blog.garytully.com Open Source Integration http://fusesource.com --001485ea0ff468938f0471f5ef9d--