Rabbitmq reading top 100 (N number) of records

456 views
Skip to first unread message

prashantr...@gmail.com

unread,
May 18, 2016, 5:43:59 PM5/18/16
to rabbitmq-users
Hi All,

I need a help here for below requirement.
I am new to Rabbitmq and not much aware about its behavior.

Currently I am communicating with Rabbitmq through BizTalk default WCF-Custom adapter.

My requirement is , currently I am able to pull only single message from rabbitmq queue in one go but I want to pull mentioned N number of messages from rabbitmq queue in one connect.

After each mentioned polling interval BizTalk WCF-Custom adapter should read only mentioned N number of messages from Rabbit.


Thank you,


Michael Klishin

unread,
May 18, 2016, 5:47:19 PM5/18/16
to rabbitm...@googlegroups.com
You can add a consumer, consume 100 messages, cancel the consumer, and requeue anything that might have been consumed
on top of that (since deliveries are server-pushed).


Your WCF adapter may or may not make that easy but RabbitMQ .NET client certainly makes that reasonably
straightforward.

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send email to rabbitm...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.



--
MK

Staff Software Engineer, Pivotal/RabbitMQ

prashantr...@gmail.com

unread,
May 18, 2016, 5:57:22 PM5/18/16
to rabbitmq-users
Thank you very much for inputs.
I am not getting here to what exactly need to do and how and where to implement the Consumer.
Can you please guide it in step wise.
Thanks again.

Michael Klishin

unread,
May 18, 2016, 5:58:24 PM5/18/16
to prashantr...@gmail.com, rabbitm...@googlegroups.com
+rabbitmq-users

No, I’m afraid I cannot offer you a step-by-step guide. Please see the tutorials and put in some effort of your own.

On 19 May 2016 at 00:56:23, prashantr...@gmail.com (prashantr...@gmail.com) wrote:
> Thank you very much for inputs.
> I am not getting here to what exactly need to do and how and where to
> implement the Consumer.
> Can you please guide it in step wise.
> Thanks again.
>
>
>
> On Wednesday, May 18, 2016 at 4:47:19 PM UTC-5, Michael Klishin wrote:
>
> > You can add a consumer, consume 100 messages, cancel the consumer, and
> > requeue anything that might have been consumed
> > on top of that (since deliveries are server-pushed).
> >
> > See tutorial 2 http://www.rabbitmq.com/getstarted.html.
> >
> > Your WCF adapter may or may not make that easy but RabbitMQ .NET client
> > certainly makes that reasonably
> > straightforward.
> >
> > On Thu, May 19, 2016 at 12:43 AM, >

prashantr...@gmail.com

unread,
May 18, 2016, 6:04:31 PM5/18/16
to rabbitmq-users
:)
I am trying to get things from tutorial which suits my requirement but unfortunately not getting way to read top N number of messages from queue in tutorial.


On Wednesday, May 18, 2016 at 4:43:59 PM UTC-5, prashantr...@gmail.com wrote:

Syed Sajid Hussain

unread,
Jan 19, 2017, 10:35:24 AM1/19/17
to rabbitmq-users
Hi Prashant,

I have a requirement to get messages from RabbitMQ as well from BizTalk but WCF binding only seems to work for messages posted to soap.amqp only...which is a temporary queue, didn't manage to make it work with durable queues, were you able to do it, if yes, would definitely like to get some details for that?

Thanks
Syed

Sandeep

unread,
Feb 7, 2017, 11:54:28 AM2/7/17
to rabbitmq-users

Hi Prashant,


I'm trying to do the same with BizTalk 2013 R2 and RabbitMQ. Please let me know if you found a solution. Appreciate your help. 



Thanks,
Sandeep 

Michael Klishin

unread,
Feb 7, 2017, 11:58:10 AM2/7/17
to rabbitm...@googlegroups.com
Either use what was recommended in

or run IModel#BasicGet 100 times (there will be a synchronous response for every basic.get request).

Besides basic.consume (which adds a long-running subscriber) and basic.get there are no other ways to consume
messages in AMQP 0-9-1.

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

Sandeep

unread,
Feb 7, 2017, 12:32:30 PM2/7/17
to rabbitmq-users
Hi Michael,

Thank you for your response. I'm also having trouble creating the .Net assemblies.

I saw in one of your previous threads to clone from Stable branch, did it. But still same issue.

Error 1 Source file '..\..\..\gensrc\RabbitMQ.Client\autogenerated-api-0-9-1.cs' could not be found
 

Michael Klishin

unread,
Feb 7, 2017, 12:40:34 PM2/7/17
to rabbitm...@googlegroups.com, Sandeep
Please start new threads for new questions. This is mailing list etiquette 101. 
> --
> You received this message because you are subscribed to the Google Groups "rabbitmq-users"
> group.
> To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
> To post to this group, send an email to rabbitm...@googlegroups.com.
Reply all
Reply to author
Forward
0 new messages