Verzögerung basierend auf Ereignissen

Question

ich die folgende Klasse haben, die eine Nachricht auf aws sns Warteschlangen „TryRestart()“ veröffentlicht:

internal class SmsReceptionTestRunner : ITestRunner<ConfigurationViaSmsAttempt> 
{ 
    private readonly CommunicationClient _communicationClient; 

    public SmsReceptionTestRunner(CommunicationClient communicationClient) 
    { 
     _communicationClient = communicationClient; 
    } 

    public Test Execute(ConfigurationViaSmsAttempt MessageType) 
    { 
     // publish 
     _communicationClient.ConfigurationService.TryRestart(MessageType.Imei); 

     // wait five minutes ...  

     return new Test("6", "", false, MessageType.TargetApn, MessageType.TargetApn); 
    } 
} 

Eine separate Handler-Klasse Pflege der Antwort nimmt, wenn es auf den Warteschlangen veröffentlicht wird - in der Regel Das dauert etwa fünf Minuten - await Task.Delay(TimeSpan.FromMinutes(5));. Nach den 5 min. wenn keine Nachrichten behandelt wurden gespeichert ich ein neues Test-Set auf false .:

public class RestartViaSmsAttemptHandler : IHandler<RestartViaSmsAttempt> 
{ 
    private readonly IRepository<Test> _TestRepository; 

    public RestartViaSmsAttemptHandler(IRepository<Test> TestRepository) 
    { 
     _TestRepository = TestRepository; 
    } 

    public bool Handle(RestartViaSmsAttempt message) 
    { 
     var test = new Test("6", message.Imei, true, "", ""); 
     _TestRepository.Save(test); 
     return true; 
    } 
} 

ich einen Mechanismus platzieren will die // wait five minutes Bit verhindern nur, wenn mein Handler bekommt eine Nachricht zurück aus den Warteschlangen zu laufen.

Im Grunde frage ich nach etwas zum Neustart und nach 5 Minuten, wenn es keine Antwort gibt, weiß ich, dass etwas schiefgelaufen ist.

Answer 1

Sie können eine Warte früh wie dieser abbrechen:

await Task.WhenAll(someTask, TimeSpan.FromMinutes(5)); 

Wenn someTask die Enden Warte abgeschlossen wird. Mit TaskCompletionSource können Sie eine Aufgabe erstellen, die nach Belieben abgeschlossen werden kann.

Wenn Sie also eine Antwort erhalten, beenden Sie die Aufgabe und beenden Sie die Wartezeit.

Sind Sie sicher, dass Sie Nachrichtenwarteschlangen benötigen? Sie führen grundsätzlich einen synchronen Aufruf über eine Nachrichtenwarteschlange aus. Vielleicht genügt ein normaler Web-Service-Anruf.