gistfile1.cs

// HOST INIT
Bus.Initialize(sbc =>
{
	sbc.SetNetwork("my-technologies");
	sbc.UseRabbitMq();
	sbc.ReceiveFrom("rabbitmq://localhost/command_host");
	sbc.SetPurgeOnStartup(true);
	sbc.Subscribe(
		s =>
			{
				registerCommandProcessors(container);
				s.LoadFrom(_processors);

				s.Handler<DiagnosticCommand>(msg =>
			               					    {
			               					        Bus.Instance.MessageContext<DiagnosticCommand>().Respond(new DiagnosticResponse());
			               					        this.Debug("Responding to DiagnosticCommand Request from {0}", msg.IssuedBy);
			               					    });
			});
});


// PUBLISHER INIT
Bus.Initialize(sbc =>
{
	sbc.SetNetwork("my-technologies");
	sbc.UseRabbitMq();
	sbc.ReceiveFrom("rabbitmq://localhost/publisher");
	sbc.SetPurgeOnStartup(true);
	sbc.Validate();
});