Nservicebus 不在 msmq 中存储订阅者答案

【问题标题】：Nservicebus doesn't store subscribers in msmqNservicebus 不在 msmq 中存储订阅者
【发布时间】：2012-05-29 19:19:15
【问题描述】：

我是 NServiceBus 的新手，我有一个问题。

我有一个 WCF 服务，它是我的发布者（我知道我不应该使用 wcf 发布）。我有另一个 WCF 服务作为订阅者。

我的问题是，当第二个 wcf 服务要订阅发布者时，我的发布者不会将此信息存储在 msmq 中（使用 .MsmqSubscriptionStorage() 时）。但是当发布者将订阅者存储在内存中时它会起作用（.InMemorySubscriptionStorage()）

如何强制我的总线使用 msmq？

下面我将给出发布者和订阅者的代码。

发布者总线初始化：

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

发布者配置：

<configSections>
        <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
        <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
        <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    </configSections>
    <MessageForwardingInCaseOfFaultConfig ErrorQueue="error"/>

订阅者总线初始化：

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

订阅者配置：

    <configSections>
        <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
        <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
        <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    </configSections>

    <MessageForwardingInCaseOfFaultConfig ErrorQueue="error"/>

    <UnicastBusConfig>
        <MessageEndpointMappings>
            <add Messages="Messages" Endpoint="FirstService" />
        </MessageEndpointMappings>
    </UnicastBusConfig>

【问题讨论】：

好的，我知道出了什么问题...在我的发布者中，我应该设置 .IsTransactional( true )，这样可以解决问题...
你应该回答你自己的问题，以便将来人们看到如果他们有同样的问题有一个答案，请参阅blog.stackoverflow.com/2012/05/encyclopedia-stack-exchange SO鼓励回答你自己的问题。

标签： c# wcf msmq nservicebus publish-subscribe

【解决方案1】：

我知道出了什么问题。 Publisher 应设置为.IsTransactional(true)，以便为订阅者使用 MSMQ 存储。

【讨论】：