qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nithesh Shetty <knitheshshe...@yahoo.com>
Subject RE: exchangeDeclare funtion hangs
Date Wed, 23 Sep 2009 12:48:03 GMT
Hi,
 
Version is qpid0.5
 
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




      
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message