In Version 4.3 the built-in Distributor has been deprecated. The new dedicated NServiceBus.Distributor.MSMQ package should be used instead.
The distributor requires an additional queue where workers can send their status updates. This is the control queue. The default address is
The distributor stores metadata about the worker availability in the the queue with the suffix
If running with NServiceBus.Host.exe, the following profiles start the endpoint with the Distributor functionality:
To start the endpoint as a Distributor install the NServiceBus.Distributor.MSMQ NuGet and then run the host from the command line, as follows:
The NServiceBus.MSMQDistributor profile instructs the NServiceBus framework to start a distributor process on this endpoint, waiting for workers to enlist to it. Unlike the NServiceBus.MSMQMaster profile, the NServiceBus.MSMQDistributor profile does not execute a worker process.
It is also possible to use the
NServiceBus. profile to start distributor and worker processes on the endpoint. To start the endpoint as a Master install the NServiceBus.Distributor.MSMQ NuGet and then run the host from the command line, as follows:
When self hosting the endpoint, use this configuration:
// Running the Distributor and a Worker busConfiguration.AsMSMQMasterNode(); // or busConfiguration.RunMSMQDistributor(); // Running the Distributor only busConfiguration.RunMSMQDistributor(false);
Any NServiceBus endpoint can run as a Worker node. To activate it, create a handler for the relevant messages and ensure that the
app. file contains routing information for the Distributor.
If hosting the endpoint with
NServiceBus., to run as a Worker, use this command line:
Configure the name of the master node server as shown in this
app. example. Note the
<configuration> <configSections> <!-- Other sections go here --> <section name="MasterNodeConfig" type="NServiceBus.Config.MasterNodeConfig, NServiceBus.Core" /> </configSections> <!-- Other config options go here --> <MasterNodeConfig Node="MachineWhereDistributorRuns"/> </configuration>
Read about the
DistributorControlAddress and the
DistributorDataAddress in the Override distributor queues (advanced) section.
If self-hosting the endpoint here is the code required to enlist the endpoint with a Distributor.
Similar to self-hosting, if running NServiceBus prior to Version 6, ensure the
app. of the worker contains the
MasterNodeConfig section to point to the hostname where the distributor process is running.
The distributor process uses two queues for its runtime operation. The
DataInputQueue is the queue where the client processes send their messages. The
ControlInputQueue is the queue where the worker nodes send their control messages.
The NServiceBus default values for these settings can be overridden, as shown in the
UnicastBusConfig section below:
<UnicastBusConfig DistributorControlAddress="EndpointName.Distributor.Control@MachineWhereDistributorRuns" DistributorDataAddress="EndpointName@MachineWhereDistributorRuns"> <MessageEndpointMappings> <!-- regular entries --> </MessageEndpointMappings> </UnicastBusConfig>
Similar to standard NServiceBus routing, it is not desirable to have high priority messages to get stuck behind lower priority messages, so just as it is possible to have separate NServiceBus processes for different message types, it is also possible to set up different distributor process instances (with separate queues) for various message types.
In this case, name the queues after the message type. For example:
SubmitPurchaseOrder. becomes the name of the distributor data queue and the input queues of each of the workers.