Rebus停止从Azure服务总线获取消息。从100条消息只有5我可以取

Question

我很新手在rebus。

我已经从零开始构建了pub/sub示例。现在我正在用户中收到消息。

我面临的问题是我发布了100条消息，然后突然当我启动订阅服务时，它仅获得100条消息中的5条消息。

Windows服务执行5次异步任务，然后熄灭。我做错了什么？

我的用户配置是这样的：

using (var activator = new BuiltinHandlerActivator()) { 
    activator.Register(() => new TestMessageHandler()); 

    Configure.With(activator) 
     .Transport(t => t.UseAzureServiceBus(Constants.connectionString, Constants.subQueue)) 
     .Routing(r => r.TypeBased().MapAssemblyOf<TestMessage>(Constants.pubQueue)‌​) 
     .Start(); 

    activator.Bus.Subscribe<TestMessage>().Wait(120000); 
} 

和我的处理程序是这样的：

public async Task Handle(TestMessage message) { 
    var message = string.Format("name: {1} and source name {2} {0} using the warp as a transport {0}", Environment.NewLine, message.Name , message.SourceName); 

    await Task.Run(() => Logger(message)); 
} 

private void Logger(TestMessage message) { 
    Console.WriteLine(message.ToString(false)); 
} 

从我张贴的代码，是有什么，我做错了什么？

Answer 1

从代码

using (var activator = new BuiltinHandlerActivator()) { 
    (...) 
    activator.Bus.Subscribe<TestMessage>().Wait(120000); 
} 

好像你的用户几乎立即处置activator，从而停止总线。

这个假设很好地符合您所遇到的行为，只处理队列中的前几条消息。

您应该在运行应用程序的整个持续时间内保持激活器实例（或者返回IBus，如果您愿意的话），然后在关闭时处置它。