I have a rhino.esb loadbalancer service running on one server named
main2, configured like so:
<facility id="video.loadbalancer">
<loadBalancer threadCount="1" endpoint="msmq://main2/
videotoencode.loadbalancer" UseFlatQueue="true"/>
</facility>
Then I have a worker service running on that same machine configured
like this:
<facility id="worker.esb">
<bus threadCount="1" numberOfRetries="5"
loadBalancerEndpoint="msmq://main2/videotoencode.loadbalancer"
endpoint="msmq://localhost/videotoencode"
queueIsolationLevel="ReadCommitted" transactional="false"/>
<messages>
<add name="Messages.VideoToEncode" endpoint="msmq://main2/
videotoencode"/>
</messages>
</facility>
This is working fine. Then I added another worker machine and
configured it exactly like the worker above. The machine is on the
same domain and the worker service runs under the same domain
account. This machine now SEES videotoencode messages, but doesn't
actually act upon them. From my logs:
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Starting the bus for Uri: msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Initating subscription storage as message module:
Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Initating message module:
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule
[2100] ENC: DEBUG
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule [(null)]
This node Uri: msmq://main2/videotoencode is load balanced by
msmq://main2/videotoencode.loadbalancer
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[(null)] Initializing msmq subscription storage on:
msmq://main2/videotoencode#subscriptions
[2100] ENC: INFO Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[(null)] Added subscription for .Messages.VideoToEncode on
msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Starting msmq transport on: Uri: msmq://main2/videotoencode
[2100] ENC: DEBUG
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule [(null)]
Telling load balancer Uri: msmq://main2/videotoencode.loadbalancer
that we Uri: msmq://main2/videotoencode are ready to do work in 1
threads
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending
message Rhino.ServiceBus.Messages.ReadyToWork to
FormatName:DIRECT=OS:main2\private$\videotoencode.loadbalancer, reply:
FormatName:DIRECT=OS:main2\private$\videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqTransport [(null)] Send
message Rhino.ServiceBus.Messages.ReadyToWork to Uri:
msmq://main2/videotoencode.loadbalancer
[2100] ENC: INFO Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Subscribing .Messages.VideoToEncode on msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending
message Rhino.ServiceBus.Messages.AddSubscription to
FormatName:DIRECT=OS:main2\private$\videotoencode, reply:
FormatName:DIRECT=OS:main2\private$\videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqTransport [(null)] Send
message Rhino.ServiceBus.Messages.AddSubscription to Uri:
msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Starting the bus for Uri: msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Initating subscription storage as message module:
Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[2100] ENC: DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Initating message module:
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule
[2100] ENC: DEBUG
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule [(null)]
This node Uri: msmq://main2/videotoencode is load balanced by
msmq://main2/videotoencode.loadbalancer
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[(null)] Initializing msmq subscription storage on:
msmq://main2/videotoencode#subscriptions
[2100] ENC: INFO Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
[(null)] Added subscription for .Messages.VideoToEncode on
msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Starting msmq transport on: Uri: msmq://main2/videotoencode
[2100] ENC: DEBUG
Rhino.ServiceBus.MessageModules.LoadBalancerMessageModule [(null)]
Telling load balancer Uri: msmq://main2/videotoencode.loadbalancer
that we Uri: msmq://main2/videotoencode are ready to do work in 1
threads
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending
message Rhino.ServiceBus.Messages.ReadyToWork to
FormatName:DIRECT=OS:main2\private$\videotoencode.loadbalancer, reply:
FormatName:DIRECT=OS:main2\private$\videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqTransport [(null)] Send
message Rhino.ServiceBus.Messages.ReadyToWork to Uri:
msmq://main2/videotoencode.loadbalancer
[2100] ENC: INFO Rhino.ServiceBus.Impl.DefaultServiceBus [(null)]
Subscribing .Messages.VideoToEncode on msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending
message Rhino.ServiceBus.Messages.AddSubscription to
FormatName:DIRECT=OS:main2\private$\videotoencode, reply:
FormatName:DIRECT=OS:main2\private$\videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.MsmqTransport [(null)] Send
message Rhino.ServiceBus.Messages.AddSubscription to Uri:
msmq://main2/videotoencode
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Got message Messages.VideoToEncode on msmq://main2/videotoencode from
null://middle/of/nowhere?turn=left
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Got message Messages.VideoToEncode on msmq://main2/videotoencode from
null://middle/of/nowhere?turn=left
[2100] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Got message Messages.VideoToEncode on msmq://main2/videotoencode from
null://middle/of/nowhere?turn=left
....repeated over and over
Meanwhile, the Loadbalancer is spamming debug messages at an alarming
rate, the same two lines over and over:
[7988] ENC: DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending
message Messages.VideoToEncode to MAIN2\private$
\videotoencode.loadbalancer, reply: no response queue
[7988] ENC: DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)]
Got message Messages.VideoToEncode on msmq://main2/videotoencode.loadbalancer
from null://middle/of/nowhere?turn=left
The loadbalancer service and encoder services are all running under
the same domain account, and that domain account has full access to
all the message queues being used.
Can anyone tell what's going on from these messages? Is it possible
I've configured rhino.esb incorrectly, or maybe I'm missing something
with my MSMQ setup?
--
You received this message because you are subscribed to the Google Groups
"Rhino Tools Dev" group.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to
[email protected].
For more options, visit this group at
http://groups.google.com/group/rhino-tools-dev?hl=en.
