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