Nservicebus 不将订阅者存储在 msmq 中
本文关键字:存储 msmq Nservicebus | 更新日期: 2023-09-27 18:34:57
我是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)
,以便对订阅服务器使用 MSMQ 存储。