Grid.Distributor ver 2.8.0 not working on my windows 7 PC

26 views
Skip to first unread message

Javier Callico

unread,
May 5, 2015, 3:09:29 PM5/5/15
to masstrans...@googlegroups.com
Hi there

I'm not able to get the Grid.Distributor sample that comes with version 2.8.0 working on my Windows 7 PC. The Activator application publishes the work items but they are not received by Worker application.

Can anybody help me troubleshooting this issue?

Javier

Chris Patterson

unread,
May 5, 2015, 4:08:56 PM5/5/15
to masstrans...@googlegroups.com
I've confirmed that the develop branch distributor works, which will ship with 2.10.


--
You received this message because you are subscribed to the Google Groups "masstransit-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to masstransit-dis...@googlegroups.com.
To post to this group, send email to masstrans...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/masstransit-discuss/8187421f-29fa-43a2-a8e3-b8f70e2bd499%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Javier Callico

unread,
May 5, 2015, 4:31:53 PM5/5/15
to masstrans...@googlegroups.com
Hi Chris

Did you have a chance to test 2.8.0 as well?

When 2.10 will be released?

Thanks.

Javier


On Tuesday, May 5, 2015 at 4:08:56 PM UTC-4, Chris Patterson wrote:
I've confirmed that the develop branch distributor works, which will ship with 2.10.

On Tue, May 5, 2015 at 12:09 PM, Javier Callico <jcal...@callicode.com> wrote:
Hi there

I'm not able to get the Grid.Distributor sample that comes with version 2.8.0 working on my Windows 7 PC. The Activator application publishes the work items but they are not received by Worker application.

Can anybody help me troubleshooting this issue?

Javier

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

Javier Callico

unread,
Jun 25, 2015, 9:03:38 AM6/25/15
to masstrans...@googlegroups.com
Chris

Now that version 2.10 has been released I took the time to revisit this subject.

Since the Distributor sample that comes with version 2.10 uses RabbitMq as transport I had to modify it to use MSMQ. What I found is that if the Control Bus is used on both endpoints the Distributor CAN NOT deliver the messages to the Worker. If I stop using the Control Bus on the Worker but I keep it on the Distributor it works as expected.

This is how both endpoints were configured:

Distributor:

            _dataBus = ServiceBusFactory.New(x =>
                {
                    //x.ReceiveFrom("rabbitmq://localhost/mt_grid_activator?prefetch=4");
                    //x.UseRabbitMq();

                    x.ReceiveFrom("msmq://localhost/mt_grid_activator");
                    x.UseMsmq(config => config.UseMulticastSubscriptionClient());
                    x.UseControlBus();

                    x.SetConcurrentConsumerLimit(4);

                    x.Subscribe(s => s.Instance(this).Transient());

                    x.Distributor(d => d.Handler<DoSimpleWorkItem>());
                });

Worker:

            _dataBus = ServiceBusFactory.New(x =>
                {
                    //x.ReceiveFrom(string.Format("rabbitmq://localhost/mt_grid_worker{0}?prefetch=20", Process.GetCurrentProcess().Id));
                    //x.UseRabbitMq();

                    x.ReceiveFrom(string.Format("msmq://localhost/mt_grid_worker{0}", Process.GetCurrentProcess().Id));
                    x.UseMsmq(config => config.UseMulticastSubscriptionClient());
                    x.UseControlBus(); // If you comment this line out it will work

                    x.SetConcurrentConsumerLimit(20);

                    x.Worker(w => w.Consumer<SimpleWorkItemConsumer>());
                });

Can you please try to replicate my findings on your side?

Any way you can explain why this is happening?

Javier 
Reply all
Reply to author
Forward
0 new messages