ConsumeContextExtension
Neos.Core.Messaging¶
Neos.Core.Messaging.Extensions¶
ConsumeContextExtension Class¶
public static class ConsumeContextExtension
Inheritance System.Object 🡒 ConsumeContextExtension
| Methods | |
|---|---|
| GetLastExecutionStartTime(ConsumeContext) | Zwraca czas startu ostatniego poprawnego przetworzenia komunikatu |
| IsExecuteCommandContext<TMessage>(ConsumeContext<TMessage>) | Sprawdza czy handler został wywołany za pomocą metody ExecuteCommand |
| SetResult<TMessage>(ConsumeContext<TMessage>, string, object) | Ustawia obiekt do zwrócenia z ExecuteCommand |
| ShouldIgnore(ConsumeContext) | Zwraca informację czy należy ignorować dany komunikat (wynik deduplikacji) Analogiczny warunek to: context.GetLastExecutionStartTime() > context.SentTime; |