我正在尝试在现有的windows服务中使用自宿主作为分发服务器.我使用MSMQ传输,以下是如何创建总线:
NServiceBus.Configure.With()
.DefaultBuilder()
.EnlistWithDistributor()
.JsonSerializer()
.UseTransport<Msmq>()
.UnicastBus()
.CreateBus()
.Start();我需要覆盖默认队列名(自动从程序集命名空间派生),我试图以以下方式定义一个EndPointConfig,不幸的是,它没有更改Q名。
[NServiceBus.EndpointName("custon.queue.name")]
public class EndpointConfig : NServiceBus.IConfigureThisEndpoint, NServiceBus.AsA_Publisher
{
public EndpointConfig()
{
}
}Config截面
<configSections>
<section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core"/>
<section name="AuditConfig" type="NServiceBus.Config.AuditConfig, NServiceBus.Core"/>
<section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core"/>
<section name="TransportConfig" type="NServiceBus.Config.TransportConfig, NServiceBus.Core"/>
</configSections>
<AuditConfig QueueName="audit"/>
<MessageForwardingInCaseOfFaultConfig ErrorQueue="error"/>
<TransportConfig MaximumConcurrencyLevel="10" MaxRetries="3" MaximumMessageThroughputPerSecond="10"/>
<UnicastBusConfig>
<MessageEndpointMappings>
<add Messages="Protocols" Endpoint="custom.queue.name@localhost"/>
</MessageEndpointMappings>
</UnicastBusConfig>如何覆盖自宿主时使用的队列的名称?
任何帮助都将不胜感激。
发布于 2013-10-16 14:18:11
当自我托管时,没有EndpointConfig类-配置完全是从fluent配置块派生出来的。您的EndpointConfig类被忽略了。
通过fluent配置,更改端点名称(具体地说“更改输入队列”是一个错误的名称-将其从端点名称中删除)的操作如下所示:
Configure.With()
.DefineEndpointName("MyEndpointName")
// Rest of config或者如果你想把它从数据库或配置文件中提取出来或者做一些花哨的事情.
Configure.With()
.DefineEndpointName(() =>
{
// determine and return endpoint name
})
// Rest of config端点名称对配置中的其他所有内容都至关重要,因此它应该是fluent配置链中的第一项。
还请参阅如何指定输入队列文档中的NServiceBus文档。
https://stackoverflow.com/questions/19359564
复制相似问题