activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Qureshi, Zeshan" <ZQure...@enghouse.com>
Subject RE: Active M Q Message Consumer blocking
Date Tue, 16 Oct 2012 18:26:45 GMT
Code snippet

                //Create Consumer and set the Message Listener
                MessageConsumer* consumerDurable;
                consumerDurable = session->createDurableConsumer(topic, applicationId,
getSelector(0), false); 
                MListener* ML = new MListener(); 
                consumerDurable->setMessageListener(ML);

                //Trying to close the Consumer and it does not return from the close request
:(
                consumerDurable->close(); //This is where the problem is 

-----Original Message-----
From: Timothy Bish [mailto:tabish121@gmail.com] 
Sent: 16 October 2012 19:22
To: users@activemq.apache.org
Subject: Re: Active M Q Message Consumer blocking

On Tue, 2012-10-16 at 18:08 +0000, Qureshi, Zeshan wrote: 
> Hi Guys,
> 
> I am experiencing an issue where I am trying to close the message consumer and it is
getting block. This happens when some producer is sending messages at the same topic where
this consumer is listening for those messages.
> 
> Any idea please? I can provide you some code snippet as well.
> 
> Thank You,
> 
> -Zeshan-

Code would help here, hard to really guess at it without some idea of the use case. 

--
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/

Mime
View raw message