Maststransit-Filter empfangene Nachricht während konsumieren

Question

Ich habe eine Frage, ist es möglich, Filter zu erstellen, um eine Nachricht zu vermeiden? Zum Beispiel ist die Nachricht:

public class ProcessingTask : IProcessingTask 
{ 
    public int Id { set; get; } 
    public string ExternalId { set; get; } 
    public ProcessingTaskStatus Status { set; get; } 
    public string Details { set; get; } 
} 

Also muss ich Nachricht an den Verbraucher weitergeben, wenn Nachricht StatusProcessingTaskStatus.Received zum Beispiel ist. Auf eine andere Weise muss die Nachricht zurückgewiesen werden.

Answer 1

So können Sie die Contentfilter verwenden, um Nachrichten zu filtern, bevor sie den Verbraucher erreichen:

configurator.Consumer(() => _consumer, x => 
    { 
     x.ConfigureMessage<IProcessingTask>(v => v.UseContentFilter(async context => context.Message.Status == ProcessingTaskStatus.Received)); 
    }); 

Sie Setup haben einen Filter für jeden Nachrichtentyp, sie individuell konfiguriert.