Re: LocalQueue get

2009-07-15 Thread Gordon Sim
you aren't seeing all the messages delivered in that mode it is something else and you should turn on tracing (--log-enable trace) for the broker to get some debug information. Regards, Nithesh --- On Wed, 7/15/09, Gordon Sim wrote: From: Gordon Sim Subject: Re: LocalQueue g

Re: LocalQueue get

2009-07-15 Thread Nithesh Shetty
face the same problem when acuiremode is PRE_ACQUIRED  settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED;   do i have to add session.sendCompletion after get ??   Regards, Nithesh   --- On Wed, 7/15/09, Gordon Sim wrote: From: Gordon Sim Subject: Re: LocalQueue get To: users@qpid.apache.org

Re: LocalQueue get

2009-07-15 Thread Gordon Sim
Nithesh Shetty wrote: Hi, I have created a thread where i open connection to broker and create a localqueue with the below configuration SubscriptionManager subscriptions(session); SubscriptionSettings settings; settings.exclusive = false; setting.flowControl = FlowControl::messageWi

LocalQueue get

2009-07-15 Thread Nithesh Shetty
Hi,   I have created a thread where i open connection to broker  and create a localqueue with the below configuration   SubscriptionManager subscriptions(session);   SubscriptionSettings settings;   settings.exclusive = false;   setting.flowControl = FlowControl::messageWindow(1);   settings.acce

Re: localqueue get

2009-07-15 Thread Gordon Sim
Nithesh Shetty wrote: Hi, the listener sample has the following settings; SubscriptionManager subscriptions(session); SubscriptionSettings settings; settings.exclusive = false; setting.flowControl = FlowControl::messageWindow(1); settings.acceptMode = ACCEPT_MODE_EXPLICIT; settings.

Re: localqueue get

2009-07-15 Thread Nithesh Shetty
 Hi,  the listener sample has the following settings;   SubscriptionManager subscriptions(session);   SubscriptionSettings settings;   settings.exclusive = false;   setting.flowControl = FlowControl::messageWindow(1);   settings.acceptMode = ACCEPT_MODE_EXPLICIT;   settings.acquireMode = ACQUIRE_MO

Re: localqueue get

2009-07-14 Thread Gordon Sim
ation. Awaiting your reply. Regards, Nithesh --- On Mon, 7/13/09, Nithesh Shetty wrote: From: Nithesh Shetty Subject: Re: localqueue get To: users@qpid.apache.org Date: Monday, July 13, 2009, 1:14 PM hi, the listener sample has the following settings; SubscriptionManager s

Re: localqueue get

2009-07-14 Thread Nithesh Shetty
ny particular reason for that or again any change in the configuration. Awaiting your reply. Regards, Nithesh --- On Mon, 7/13/09, Nithesh Shetty wrote: From: Nithesh Shetty Subject: Re: localqueue get To: users@qpid.apache.org Date: Monday, July 13, 2009, 1:14 PM hi,    the listener samp

Re: localqueue get

2009-07-13 Thread Gordon Sim
Nithesh Shetty wrote: hi, the listener sample has the following settings; SubscriptionManager subscriptions(session); SubscriptionSettings settings; settings.acceptMode = ACCEPT_MODE_EXP; settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED; LocalQueue local_queue; subscriptions.subscribe(l

Re: localqueue get

2009-07-13 Thread Nithesh Shetty
our reply.   Nithesh     --- On Mon, 7/13/09, Gordon Sim wrote: From: Gordon Sim Subject: Re: localqueue get To: users@qpid.apache.org Date: Monday, July 13, 2009, 11:34 AM Nithesh Shetty wrote: > the listener sample has the following settings; > SubscriptionManager subscriptions(session); >

Re: localqueue get

2009-07-13 Thread Gordon Sim
Nithesh Shetty wrote: the listener sample has the following settings; SubscriptionManager subscriptions(session); SubscriptionSettings settings; settings.acceptMode = ACCEPT_MODE_NONE; settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED; LocalQueue local_queue; subscriptions.subscribe(local_queue, "

localqueue get

2009-07-13 Thread Nithesh Shetty
Hi I have created a producer=A0sample with the following option: QueueOptions queueOptions; queueOptions.setOrdering(FIFO); session.exchangeDeclare(arg::exchange="QM", arg::exclusive = false, arg::autoDelete = false, arg::type = "direct"); session.queueDeclare(arg::queue="RMS", arg::exclusive = f

Re: Potential deadlock with LocalQueue::get() / Session::close()?

2009-03-03 Thread Gordon Sim
Rob Springer wrote: Hey all - I've noticed a problem when debugging some code, and it looks to my eyes like there's a potential deadlock situation using the timed LocalQueue::get() command when a fatal interrupt occurs. I've posted what I hope is clear reproducer code below. Cou

Potential deadlock with LocalQueue::get() / Session::close()?

2009-03-03 Thread Rob Springer
Hey all - I've noticed a problem when debugging some code, and it looks to my eyes like there's a potential deadlock situation using the timed LocalQueue::get() command when a fatal interrupt occurs. I've posted what I hope is clear reproducer code below. Could someone else take