Hi Bikram,<div><br></div><div>Why don't you place the deduplication on producer side? E.g. consumer sends back messages that the task has been processed, and the producer only puts the task into the queue if the last one has already been processed.<br>
<br><div class="gmail_quote">On Sat, Jan 7, 2012 at 12:14 AM, Bikram Bhuyan <span dir="ltr"><<a href="mailto:bikrambhuyan@gmail.com">bikrambhuyan@gmail.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<p>Hi Guys,</p>
<p></p>
<p>I need some help in my below requirement for implementing RabbitMQ for .NET. Could you please help me in providing right pointer to API which can be used to achieve this task.<br></p>
<p>1. I am right now working on a batch process in C# .net
with RabbitMQ as the communication channel. </p>
<p>2. I have one producer which runs every 15 minutes and
put the request to the queue with the TaskId (Say 12345) to the Queue.</p>
<p>3. My consumer takes the TaskId from the queue and
process the other logic.</p>
<p></p>
<p>The consumer normally takes a lot of time to complete the
task around 30 minutes or more, as it is a batch process which do a lot of
activities. So a lot of request are added to the queue by producer modules. So
I am having a lot of back logs for the same task id (12345) over a period of
time.</p>
<p></p>
<p>So I wanted to implement the logic that if the message
(12345) already exists in the queue (not processed completely) I don�t wanted
to add it to the queue for this id (12345). Could you please send me the
details of the API calls which will give me the list of messages in a queue so
that I can have my own logic to check if the message already exists.</p>
<p></p><p>Thanks,</p><p></p>
<p>Bikram.</p>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br><br clear="all"><div><br></div>-- <br>Eugene Kirpichov<br>Principal Engineer, Mirantis Inc. <a href="http://www.mirantis.com/" target="_blank">http://www.mirantis.com/</a><br>Editor, <a href="http://fprog.ru/" target="_blank">http://fprog.ru/</a><br>
</div>