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/22 12:15:26 UTC

qpid-0.10 queries

<div class="plainMail">&lt;div class="plainMail"&gt;Hi,&lt;BR&gt;&lt;BR&gt;When qpid-0.8 was release we had created a wrapper on the api provided&lt;BR&gt;&lt;BR&gt;Session.exchangeDeclare(arg::exchange, arg::exclusive, arg::durable, arg::autoDelete, arg::type);&lt;BR&gt;Session.queueDeclare(arg::queue, arg::exclusive, arg::durable, arg::autoDelete, arg::arguments);&lt;BR&gt;Session.exchangeBind(arg::exchange, arg::queue, arg::bindingkey);&lt;BR&gt;&lt;BR&gt;Sending&lt;BR&gt;async(m_cSession).messageTransfer(arg::content, arg::destination, arg::acceptMode, &lt;BR&gt;&amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;&amp;nbsp;&amp;nbsp;arg::acquireMode,
 arg::sync);&lt;BR&gt;&lt;BR&gt;Browsing&lt;BR&gt;Settings.acquireMode = ACQUIRE_MODE_NOT_REQUIRED;&lt;BR&gt;Subscription-&amp;gt;subscribe(BrowsLocalQueue, queuename, Settings, "BROWSE");&lt;BR&gt;&lt;BR&gt;BrowseLocalQueue.get(Message, TIME_INFINITE);&lt;BR&gt;&lt;BR&gt;Receiving&lt;BR&gt;Settings.acquireMode =<BR> ACQUIRE_MODE_PRE_ACQUIRED;&lt;BR&gt;Subscription.subscribe(ReadLocalQueue, queuename, Setting, "READ");&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;now my problem&lt;BR&gt;&lt;BR&gt;when i use the same implementation in qpid0-10 to browse msg and process the data recevied and&lt;BR&gt;remove the msg by reading it.&lt;BR&gt;&lt;BR&gt;Then many times when the queue depth is one the&lt;BR&gt;&lt;BR&gt;browsing queue get gives me message whose content is empty and Content length is 0&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;BR&gt;&lt;/div&gt;<BR></div>

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org