From 8c8265607556f71fb62c3ae11aefc0136a651713 Mon Sep 17 00:00:00 2001 From: Sebastian Date: Sat, 4 Feb 2017 18:50:33 +0100 Subject: [PATCH] Fix --- src/Squidex.Infrastructure.RabbitMq/RabbitMqEventBus.cs | 8 ++++---- src/Squidex/Config/Domain/EventBusModule.cs | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/Squidex.Infrastructure.RabbitMq/RabbitMqEventBus.cs b/src/Squidex.Infrastructure.RabbitMq/RabbitMqEventBus.cs index 6241b4221..c7fce966c 100644 --- a/src/Squidex.Infrastructure.RabbitMq/RabbitMqEventBus.cs +++ b/src/Squidex.Infrastructure.RabbitMq/RabbitMqEventBus.cs @@ -20,12 +20,12 @@ namespace Squidex.Infrastructure.RabbitMq { private readonly bool isPersistent; private const string Exchange = "Squidex"; - private readonly IConnectionFactory connectionFactory; + private readonly ConnectionFactory connectionFactory; private readonly Lazy connection; private readonly Lazy channel; private EventingBasicConsumer consumer; - public RabbitMqEventBus(IConnectionFactory connectionFactory, bool isPersistent) + public RabbitMqEventBus(ConnectionFactory connectionFactory, bool isPersistent) { Guard.NotNull(connectionFactory, nameof(connectionFactory)); @@ -61,12 +61,12 @@ namespace Squidex.Infrastructure.RabbitMq if (!currentConnection.IsOpen) { - throw new ConfigurationException($"RabbitMq event bus failed to connect to {connectionFactory.VirtualHost}"); + throw new ConfigurationException($"RabbitMq event bus failed to connect to {connectionFactory.Endpoint}"); } } catch (Exception e) { - throw new ConfigurationException($"RabbitMq event bus failed to connect to {connectionFactory.VirtualHost}", e); + throw new ConfigurationException($"RabbitMq event bus failed to connect to {connectionFactory.Endpoint}", e); } } diff --git a/src/Squidex/Config/Domain/EventBusModule.cs b/src/Squidex/Config/Domain/EventBusModule.cs index 225269be8..7afbfaf3d 100644 --- a/src/Squidex/Config/Domain/EventBusModule.cs +++ b/src/Squidex/Config/Domain/EventBusModule.cs @@ -67,6 +67,7 @@ namespace Squidex.Config.Domain }) .As() .As() + .As() .SingleInstance(); } else