Как правильно настроить WebApi, EasyNetQ и Ninject?

Question

Это то, что я имею до сих пор. Я застрял в концепции / где реализовать точку ввода / создания IBus (издатель). Я пытался сохранить функциональность издателя в рамках всего проекта, а не создавать для него отдельный сервис.

   bus = RabbitHutch.CreateBus("host=localhost", x => x.Register<IEasyNetQLogger>(_ => logger));

Это мой первый проход, поэтому я открыт для предложений и советов передовой практики:-)

Что осталось сделать:

• создать файл конфигурации rabbitmq с правильными настройками, определяющими имя очереди и?
• создать обработчик сообщений, который позаботится об управлении соединениями?
• создать издателя при запуске приложения, правильно утилизировать, когда?

EasyNetQ Wrapper для замены внутреннего IoC EasyNetQ, замена Ninject:

  public class NinjectContainerWrapper: IContainer, IDisposable
  {

    public NinjectContainerWrapper()
    {

    }

    //ninject container/kernal? here
    //private readonly ISomeNinjectInterface container;
    public TService Resolve<TService>() where TService : class
    {
        throw new NotImplementedException();
    }

    public IServiceRegister Register<TService, TImplementation>()
        where TService : class
        where TImplementation : class, TService
    {
        throw new NotImplementedException();
    }

    public IServiceRegister Register<TService>(Func<EasyNetQ.IServiceProvider, TService> serviceCreator) where TService : class
    {
        throw new NotImplementedException();
    }

    public void Dispose()
    {
        throw new NotImplementedException();
    }
  }

NinjectWebCommon.cs

  private static void RegisterServices(IKernel kernel)
  {
        kernel.Bind<IAppSettings>().To<AppSettings>();
        kernel.Bind<IDmpeService>().To<DmpeService>();
        kernel.Bind<IPublisher>().To<DmpePublisher>();
        kernel.Bind<IEasyNetQLogger>().To<GdmEasyNetQLogger>();
        kernel.Bind<ILoggingService>().ToMethod(x =>
        {
            var scope = x.Request.ParentRequest.Service.FullName;
            var log = (ILoggingService)LogManager.GetLogger(scope, typeof(LoggingService));
            return log;
        });
    }        

класс издателя:

  public class DmpePublisher: IPublisher
  {
    private readonly IEasyNetQLogger _logger;
    private readonly IAppSettings _appSettings;
    private readonly IBus bus = null;

    public DmpePublisher(IEasyNetQLogger logger, IAppSettings appSettings)
    {
        this._logger = logger;
        this._appSettings = appSettings;

        // register our alternative container factory
        RabbitHutch.SetContainerFactory(() =>
        {
            var ninjectContainer = new NinjectContainerWrapper();

            // wrap it in our implementation of EasyNetQ.IContainer
            //return new NinjectContainerWrapper(ninjectContainer);
        });

         bus = RabbitHutch.CreateBus("host=localhost", x => x.Register<IEasyNetQLogger>(_ => logger));
    }

    public void PublishMessage(Messages.IMessage message)
    {
        throw new NotImplementedException();
        //log post
        //_logger.InfoWrite("Publishing message: {0}", message);
    }
 }