diff --git a/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/Installer.cs b/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/Installer.cs index 062bedf4599..8becef0c715 100644 --- a/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/Installer.cs +++ b/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/Installer.cs @@ -1,8 +1,5 @@ -using System; -using System.Collections.Generic; -using System.Linq; -using System.Security.Principal; -using System.Text; +using System.Security.Principal; +using NServiceBus.Config; using NServiceBus.Installation; using NServiceBus.Utils; @@ -16,6 +13,11 @@ public void Install(WindowsIdentity identity) return; MsmqUtilities.CreateQueueIfNecessary(Address.Local, identity.Name); + + var unicastConfig = Configure.GetConfigSection(); + if (unicastConfig != null) + if (!string.IsNullOrEmpty(unicastConfig.ForwardReceivedMessagesTo)) + MsmqUtilities.CreateQueueIfNecessary(unicastConfig.ForwardReceivedMessagesTo, identity.Name); } } } diff --git a/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/NServiceBus.Unicast.Queuing.Msmq.Config.csproj b/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/NServiceBus.Unicast.Queuing.Msmq.Config.csproj index ec26e9c0404..88a1e1828c1 100644 --- a/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/NServiceBus.Unicast.Queuing.Msmq.Config.csproj +++ b/src/impl/unicast/queuing/NServiceBus.Unicast.Queuing.Msmq.Config/NServiceBus.Unicast.Queuing.Msmq.Config.csproj @@ -58,6 +58,10 @@ ..\..\..\..\..\build\nservicebus.core\NServiceBus.Unicast.dll False + + ..\..\..\..\..\build\nservicebus.core\NServiceBus.Unicast.Config.dll + False + False ..\..\..\..\..\build\nservicebus.core\NServiceBus.Unicast.Queuing.dll