Начало работы со служебной шиной Rhino

после загрузки последних версий Rhino-ESB с github (https://github.com/hibernating-rhinos/rhino-esb) и их сборки начать работу довольно просто.

У меня есть приложение asp.net MVC, которое взаимодействует с серверной частью через Rhino-ESB.

На стороне asp.net MVC:

На global.asax.cs:

private IWindsorContainer _container;

protected void Application_Start()
{
    _container = new WindsorContainer();
    new RhinoServiceBusConfiguration().UseCastleWindsor(_container).Configure();
    _container.Install(new YourCustomInstaller());
    //Don't forget to start the bus
    _container.Resolve<IStartableServiceBus>().Start();
    ControllerBuilder.Current.SetControllerFactory(new WindsorControllerFactory(_container));
}

Обратите внимание, что YourCustomInstaller должен реализовать IWindsorInstaller, и вы регистрируете свои контроллеры в контейнере в методе Install:

public void Install(Castle.Windsor.IWindsorContainer container, Castle.MicroKernel.SubSystems.Configuration.IConfigurationStore store)
{
    container.Register(Component
       .For<HomeController>().LifeStyle.PerWebRequest.ImplementedBy<HomeController>());

Также обратите внимание, что WindsorControllerFactory внутренне делегирует создание контроллера контейнеру:

protected override IController GetControllerInstance(RequestContext requestContext, Type controllerType)
    {
        if (controllerType == null)
            return null;
        return (IController)this.container.Resolve(controllerType);
    }

И последнее, но не менее важное: укажите конфигурацию в файле web.config.

<configSections>
    <section name="rhino.esb" type="Rhino.ServiceBus.Config.BusConfigurationSection, Rhino.ServiceBus"/>
  </configSections>
  <rhino.esb>
    <bus threadCount="1"
         numberOfRetries="5"
         endpoint="rhino.queues://localhost:31316/Client"
         queueIsolationLevel="ReadCommitted"
         name="Client"/>
    <messages>
      <add name="YourMessagesNamespace"endpoint="rhino.queues://localhost:31315/Backend"/>
    </messages>
  </rhino.esb>

Эта конфигурация предполагает, что бэкэнд запускает очередь на локальном хосте: 31315, а клиент запускает свою очередь на локальном хосте: 31316.

На стороне сервера: если мы запускаем его как консольное приложение,

static void Main(string[] args)
        {
            IWindsorContainer container;
            container = new WindsorContainer();
            new RhinoServiceBusConfiguration()
                .UseCastleWindsor(container)
                .Configure();
            var host = new RemoteAppDomainHost(typeof(YourBootstrapper));
            host.Start();

            Console.WriteLine("Starting to process messages");
            Console.ReadLine();

Обратите внимание, что YourBootstrapperclass реализует CastleBootstrapper

public class YourBootstrapper: Rhino.ServiceBus.Castle.CastleBootStrapper
    {
        protected override void ConfigureContainer()
        {
            Container.Register(Component.For<OneOfYourMessages>());
        }
    }

в котором мы регистрируем потребителя для OneOfYourMessages