未在NServiceBus中自动创建队列

本文关键字:创建 队列 NServiceBus 未在 | 更新日期: 2023-09-27 18:22:23

我正在运行NServiceBus 3.0.0 rc2,但当我在没有预先创建MSMQ的情况下启动应用程序(作为本地管理员)时,它会错误为:

队列不存在,或者您没有足够的权限执行该操作。

使用NServiceBus 2.6时没有发生这种情况。

以下是我的配置:

var bus = Configure.With()
    .Log4Net()
    .NinjectBuilder()
    .XmlSerializer()
    .DefiningCommandsAs(t => typeof(ICommand).IsAssignableFrom(t))
    .DefiningEventsAs(t => typeof(IEvent).IsAssignableFrom(t))
    .DefiningMessagesAs(t => typeof(IMessage).IsAssignableFrom(t))
    .MsmqTransport()
        .DefineEndpointName("subscriber.input")
        .IsTransactional(true)
        .PurgeOnStartup(false)
    .UnicastBus()
        .LoadMessageHandlers() 
        .ImpersonateSender(false)
    .CreateBus()
    .Start();

<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>    
  <MsmqTransportConfig ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5" />    
  <UnicastBusConfig>
    <MessageEndpointMappings>
      <add Messages="MyEvents" Endpoint="publisher.input" />
    </MessageEndpointMappings>
  </UnicastBusConfig>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/>
  </startup>
</configuration>

我可以看到一个配置扩展方法来禁用自动创建队列,但没有启用它

如果我预先创建队列,它可以正常工作。

未在NServiceBus中自动创建队列

自托管时,安装程序不会自动运行。有关如何手动操作的示例,请参阅asyncpages示例中的global.asax.cs。

using NServiceBus
using NServiceBus.Installation.Environments
...
Bus = Configure.With()
    .Log4Net()
    .DefaultBuilder()
    .XmlSerializer()
    .MsmqTransport()
    .IsTransactional(false)
    .PurgeOnStartup(false)
    .UnicastBus()
    .ImpersonateSender(false)
    .CreateBus()
    .Start(() => Configure.Instance.ForInstallationOn<Windows>().Install());

我通过手动在客户端创建队列(它是自托管的)来解决这个问题。

不确定,但我认为2.x是自动完成的。正如预期的那样,主机正在自动创建队列,但不是客户端(自托管)。

更新:就像Andreas,senor guardo camino所说的,你需要手动调用install;

.Start(() => Configure.Instance.ForInstallationOn<NServiceBus.Installation.Environments.Windows>().Install());

这将按预期创建队列。