masstransit過濾收到消息，同時消耗

Question

我有一個問題，是否有可能創建過濾器來防止消費一條消息？ 例如消息是：

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

所以我需要傳遞信息給消費者，如果消息Status是ProcessingTaskStatus.Received例如。另一方面，該消息需要被拒絕。

Answer 1

所以，你可以使用ContentFilter過濾掉郵件到達消費者面前：

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

你必須設定每個消息類型的過濾器，它們單獨配置。