Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of tabish121@gmail.com
 designates 209.85.128.51 as permitted sender)
Message-ID: <517935C0.8060101@gmail.com>
Date: Thu, 25 Apr 2013 09:55:12 -0400
From: Timothy Bish <tabish121@gmail.com>
User-Agent: Mozilla/5.0 (X11; Linux x86_64;
 rv:17.0) Gecko/20130329 Thunderbird/17.0.5
MIME-Version: 1.0
To: users@activemq.apache.org
Subject: Re: Not receiving all msgs from queue
References: <1366887651386-4666192.post@n4.nabble.com>
In-Reply-To: <1366887651386-4666192.post@n4.nabble.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

On 04/25/2013 07:00 AM, erngarfen wrote:
> Hi all,
>
> I've been struggling with this for a while now, but still can't get my
> client to receive all the messages from a queue. I'm using ActiveMQ 5.8.0 as
> the broker and ActiveMQ-CPP for the client (see simple test code below). At
> the broker I have a queue filled with 1000 messages (done from a separate
> python script). When I try to receive these, I usually end up with 575 or
> 588 received messages. Trying some combinations of 'prefetch' doesn't help
> me either. If I start to acknowledge messages, I'll receive the 1000
> messages.
>
> I can see in Wireshark that 'MessagePull' is sent to the broker but the
> 'MessageDispatch' reply doesn't contain the 'message body'.
>
> Any help appreciated.
> Thanks.
>
>
> #include "activemq/library/ActiveMQCPP.h"
> #include "cms/ConnectionFactory.h"
> #include "cms/Connection.h"
> #include "cms/Session.h"
>
> #include <iostream>
>
> int main()
> {
> 	using namespace cms;
> 	using namespace activemq::library;
>
> 	ActiveMQCPP::initializeLibrary();
>
> 	ConnectionFactory* lFactory	   =
> ConnectionFactory::createCMSConnectionFactory("tcp://10.178.230.119:61616?jms.prefetchPolicy.queuePrefetch=0");
> 	Connection*		   lConnection = lFactory->createConnection();
> 	Session*		   lSession	   =
> lConnection->createSession(Session::INDIVIDUAL_ACKNOWLEDGE);
> 	Queue*			   lQueue	   =
> lSession->createQueue("cmd.queue?consumer.prefetchSize=0");
> 	MessageConsumer*   lConsumer   = lSession->createConsumer(lQueue);
>
> 	const ConnectionMetaData* lMetaData = lConnection->getMetaData();
> 	std::cout << "AMQ version=" << lMetaData->getProviderVersion() <<
> std::endl;
>
> 	lSession->start();
>
> 	int lCnt = 0;
> 	while (true)
> 	{
> 		if (Message* lMsg = lConsumer->receive(1000))
> 		{
> 			std::cout << "Received msg #" << ++lCnt << std::endl;
> 			delete lMsg;
> 		}
> 	}
> }
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Not-receiving-all-msgs-from-queue-tp4666192.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Is your producer blocking be cause its being flow controlled.  You 
aren't acking the messages so space won't be free in memory usage until 
you do.

-- 
Tim Bish
Sr Software Engineer | RedHat Inc.
tim.bish@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/