qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gordon Sim <g...@redhat.com>
Subject Re: exchangeDeclare funtion hangs
Date Wed, 23 Sep 2009 19:38:11 GMT
On 09/23/2009 01:48 PM, Nithesh Shetty wrote:
> Hi,
>
> Version is qpid0.5

Can you run pstack against both the client and qpidd processes at the 
point of the hang?

>
> I have created a class called CMessageQueue
> it has two Function called OpenConnection  and OpenQueue
>
> member variables are
> Session m_cSession
> Connection m_cConnection.
>
> int CMessageQueue:: OpenConnection(const string szHost,
>                                                                          const short
int nPort,
>                                                                            const string
szUserName,
>                                                                           const string
szPassword)
>
> {
> Connection Settings lcConnSettings;
> lcConnSettings.host = szHost;
> lcConnSettings.port = nPort;
> lcConnSettings.maxFramesize = 2046;
> lcConnSettings.virtualhost = "/";
> lcConnSettings.username = szUserName; //guest
> lcConnSettings.password = szPassword; //guest
>
> if (!m_cConnection.isOpen)
> {
>    m_cConnection.open(lcConnSettings);
>    m_cSession = m_cConnection.newSession();
> }
> }
>
> int CMessageQueue::openQueue(const QueueOrderingPolicy cQOP)
> {
>     QueueOptions lcQueueOptions;
>     lcQueueOptions.setOrdering(cQOP);
>
>   m_cSession.exchangeDeclare(arg::exchange = "alter_exch", arg::exclusive = false, arg::autoDelete
= false, arg::type = "direct"); //hangs here
> m_cSession.queueDeclare(arg::queue = "alter_queue", arg::exclusice =false, arg::autoDelete
= false, arg::arguments = lcQueueOptions);
> m_cSession.exchangeBind(arg::exchange = "alter_exch", arg::queue = "alter_queue", arg::bindingKey
= "key");
>
>   m_cSession.exchangeDeclare(arg::exchange = "exch", arg::exclusive = false, arg::autoDelete
= false, arg::type = "direct");
> m_cSession.queueDeclare(arg::queue = "queue", arg::exclusice =false, arg::autoDelete
= false, arg::arguments = lcQueueOptions, arg::alternateExchange = "alter_exch");
> m_cSession.exchangeBind(arg::exchange = "exch", arg::queue = "queue", arg::bindingKey
= "key");
>
>
> }
>
> Now after calling OpenConnection
> i call OpenQueue then its hangs at exchangeDeclare
>
> Regards,
> NIthesh
>
> --- On Wed, 9/23/09, Steve Huston<shuston@riverace.com>  wrote:
>
>
> From: Steve Huston<shuston@riverace.com>
> Subject: RE: exchangeDeclare funtion hangs
> To: users@qpid.apache.org
> Date: Wednesday, September 23, 2009, 12:20 PM
>
>
> Hi Nitesh,
>
> What version of Qpid do you see this problem in? Could you post a
> small test program that reproduces this?
>
> Thanks,
> -Steve
>
> --
> Steve Huston, Riverace Corporation
>
>> -----Original Message-----
>> From: Nithesh Shetty [mailto:knitheshshetty@yahoo.com]
>> Sent: Wednesday, September 23, 2009 8:01 AM
>> To: users@qpid.apache.org
>> Subject: exchangeDeclare funtion hangs
>>
>>
>> Hi,
>>
>> When I try to declare exchange using
>> Session.exchangeDeclare(arg::exchange = "NAME",
>> arg::exclusive = false, arg::autoDelete = false, arg::type =
>> "direct");
>>
>>
>> it hangs in
>> VOID Condition::wait(Mutex&  mutex)
>> {
>>      QPID_POSIX_ASSERT_THROW_IF(pthread_cond_destroy(&condition));
>> }
>>
>> Need help to proceed.
>>
>> Regards,
>> 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


Mime
View raw message