<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:[email protected]

Reply via email to