Rebus arrête de récupérer les messages du bus de service azure. À partir de 100 messages seulement 5 Je pouvais aller chercher

Question

Je suis très novice chez rebus.

J'ai construit l'exemple pub/sub à partir de zéro. Maintenant, je reçois des messages dans mon abonné. Le problème que je suis confronté est que je publie 100 messages et soudainement quand je démarre le service d'abonné il obtient seulement 5 de ces 100 messages.

Le service Windows effectue la tâche asynchrone 5 fois, puis s'éteint. Est-ce que je fais quelque chose de mal?

Ma configuration d'abonné ressemble à ceci:

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); 
} 

et mon gestionnaire ressemble à ceci:

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)); 
} 

À partir du code que j'ai posté, est-il quelque chose que je fait de mal?

Answer 1

À partir du code

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

il semble que votre abonné presque immédiatement disposer le activator et ainsi arrêter le bus.

Cette hypothèse correspond parfaitement au comportement que vous rencontrez lorsque seuls les premiers messages de la file d'attente sont traités. Vous devez conserver l'instance de l'activateur (ou la IBus renvoyée si vous préférez) en tant que singleton pendant toute la durée d'exécution de votre application, puis la disposer à l'arrêt.