You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Nithesh Shetty <kn...@yahoo.com> on 2011/07/26 17:51:34 UTC
Qpid 0.10 Browse Issue
Hi,
i have created a receiver in browse mode. the receiver is waiting to fetch a msg.
now i have another application that send message on the same queue.
Many times fetch gets stuck it does not return even if there is message in the queue.
Duration is INFINITE.
Awaiting your reply.
Nithesh
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Gordon Sim <gs...@redhat.com>.
On 07/27/2011 02:09 PM, Nithesh Shetty wrote:
> I am another problem i close my testing application
>
> In my testing application
> i have opened a connection created a session and then created a sender
> for queue which is durable.
>
>
>
>
> it raises exception saying Invalid argument
> ./include/qpid/sys/posix/Mutex.h:116: void qpid::sys::Mutex::lock(): Assertion '0' failed
If you create a reproducer and attach it to a new JIRA, that will make
it easier to determine what the issue is.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Nithesh Shetty <kn...@yahoo.com>.
I am another problem i close my testing application
In my testing application
i have opened a connection created a session and then created a sender
for queue which is durable.
it raises exception saying Invalid argument
../include/qpid/sys/posix/Mutex.h:116: void qpid::sys::Mutex::lock(): Assertion '0' failed
Need help
Regards,
Nithesh
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Gordon Sim <gs...@redhat.com>.
On 07/27/2011 06:36 AM, Nithesh Shetty wrote:
> Any api to get the depth of queue
>
> and to purge all the messages in the queue
You have several options. Either you can use tools provided (qpid-stat
and qpid-tool), or you can use the QMF (Qpid Management Framework)
APIs[1], or you can directly send management messages using the
management API. There are examples of both these tasks given in the
following mails:
http://mail-archives.apache.org/mod_mbox/qpid-users/201105.mbox/%3C4DD52D7A.3080508@redhat.com%3E
http://mail-archives.apache.org/mod_mbox/qpid-users/201008.mbox/%3C4C727592.9020109@redhat.com%3E
[1] The APIs are available from:
For python:
https://svn.apache.org/repos/asf/qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
or in the qpid-qmf download
For c++:
https://svn.apache.org/repos/asf/qpid/trunk/qpid/cpp/include/qmf also
part of qpid-cpp
I'm not aware of any documentation for these APIs and am myself not
terribly familiar with them.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Nithesh Shetty <kn...@yahoo.com>.
Any api to get the depth of queue
and to purge all the messages in the queue
--- On Tue, 7/26/11, Nithesh Shetty <kn...@yahoo.com> wrote:
> From: Nithesh Shetty <kn...@yahoo.com>
> Subject: Re: Qpid 0.10 Browse Issue
> To: users@qpid.apache.org
> Date: Tuesday, July 26, 2011, 4:56 PM
>
> ok i will do that
>
> but i think i have found the bug in my test app.
>
> just wanted to know how to handle if queue is empty
> i know it gives exception
>
> what i want to check is that if the queue is empty
> and there is no message
>
> then it should not exit it should go back again to read
>
> any return type of any indication that the exception raised
> is
>
> queue is empty
>
> another query is any api to purge queue and to get the
> depth of the queue
>
> actaully we want to used qpid to replace websphere mq.
>
> need your help.
>
> thanks
>
> Regards,
>
> Nithesh
>
>
>
> --- On Tue, 7/26/11, Gordon Sim <gs...@redhat.com>
> wrote:
>
> > From: Gordon Sim <gs...@redhat.com>
> > Subject: Re: Qpid 0.10 Browse Issue
> > To: users@qpid.apache.org
> > Date: Tuesday, July 26, 2011, 4:22 PM
> > On 07/26/2011 04:51 PM, Nithesh
> > Shetty wrote:
> > > Hi,
> > >
> > > i have created a receiver in browse mode. the
> receiver
> > is waiting to fetch a msg.
> > >
> > > now i have another application that send message
> on
> > the same queue.
> > >
> > > Many times fetch gets stuck it does not return
> even if
> > there is message in the queue.
> > >
> > > Duration is INFINITE.
> > >
> > > Awaiting your reply.
> >
> > Can you send a simple test case? Works as expected for
> me.
> >
> >
> ---------------------------------------------------------------------
> > Apache Qpid - AMQP Messaging Implementation
> > Project: http://qpid.apache.org
> > Use/Interact: mailto:users-subscribe@qpid.apache.org
> >
> >
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Nithesh Shetty <kn...@yahoo.com>.
ok i will do that
but i think i have found the bug in my test app.
just wanted to know how to handle if queue is empty
i know it gives exception
what i want to check is that if the queue is empty
and there is no message
then it should not exit it should go back again to read
any return type of any indication that the exception raised is
queue is empty
another query is any api to purge queue and to get the depth of the queue
actaully we want to used qpid to replace websphere mq.
need your help.
thanks
Regards,
Nithesh
--- On Tue, 7/26/11, Gordon Sim <gs...@redhat.com> wrote:
> From: Gordon Sim <gs...@redhat.com>
> Subject: Re: Qpid 0.10 Browse Issue
> To: users@qpid.apache.org
> Date: Tuesday, July 26, 2011, 4:22 PM
> On 07/26/2011 04:51 PM, Nithesh
> Shetty wrote:
> > Hi,
> >
> > i have created a receiver in browse mode. the receiver
> is waiting to fetch a msg.
> >
> > now i have another application that send message on
> the same queue.
> >
> > Many times fetch gets stuck it does not return even if
> there is message in the queue.
> >
> > Duration is INFINITE.
> >
> > Awaiting your reply.
>
> Can you send a simple test case? Works as expected for me.
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Gordon Sim <gs...@redhat.com>.
On 07/26/2011 04:51 PM, Nithesh Shetty wrote:
> Hi,
>
> i have created a receiver in browse mode. the receiver is waiting to fetch a msg.
>
> now i have another application that send message on the same queue.
>
> Many times fetch gets stuck it does not return even if there is message in the queue.
>
> Duration is INFINITE.
>
> Awaiting your reply.
Can you send a simple test case? Works as expected for me.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org
Re: Qpid 0.10 Browse Issue
Posted by Nithesh Shetty <kn...@yahoo.com>.
I have found the error i had set capacity for receiver as 100.
and the msgdepth in the queue was ten so
for some reason it use to raise NoMemoryException error.
I has set capacity as 100 assuming that it will pre fetch the message
and when i call fetch
the whole process of getting the message will be faster.
Nithesh
--- On Tue, 7/26/11, Nithesh Shetty <kn...@yahoo.com> wrote:
> From: Nithesh Shetty <kn...@yahoo.com>
> Subject: Qpid 0.10 Browse Issue
> To: users@qpid.apache.org
> Date: Tuesday, July 26, 2011, 3:51 PM
> Hi,
>
> i have created a receiver in browse mode. the receiver is
> waiting to fetch a msg.
>
> now i have another application that send message on the
> same queue.
>
> Many times fetch gets stuck it does not return even if
> there is message in the queue.
>
> Duration is INFINITE.
>
> Awaiting your reply.
>
> Nithesh
>
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
>
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org