MassTransit:有记录传入消息的方法吗？
MassTransit:有记录传入消息的方法吗？
提问于 2016-09-26 23:06:17
我想要记录我在MassTransit中使用的每一条消息。有没有一种方法可以实现全局拦截器，在那里我可以处理传入消息或使用配置来实现？
我当前的配置如下所示：
BusFactory = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(new Uri(AppSettings.RmqConnectionString), h => { });
cfg.UseNLog();
cfg.ReceiveEndpoint(host, RmqPropertyKeys.CallbackQueue, e=> e.LoadFrom(container));
});回答 2
Stack Overflow用户
回答已采纳
发布于 2016-09-27 12:40:06
文档包括一个示例中间件筛选器，它就是这样做的，记录传递给消费者的每一条消息。
http://masstransit-project.com/advanced/middleware/custom.html
如果您愿意，也可以使用内置的LogFilter：
cfg.UseLog(Console.Out, (context,logContext) => $"Format your log message");Stack Overflow用户
发布于 2018-05-28 20:06:46
另一种方法是使用ConsumeObserver。
实现接口IConsumeObserver：
public class ConsumeObserver : IConsumeObserver
{
private readonly ILogger<ConsumeObserver> _logger;
public ConsumeObserver(ILogger<ConsumeObserver> logger)
{
_logger = logger;
}
public Task ConsumeFault<T>(ConsumeContext<T> context, Exception exception) where T : class
{
//use _logger
return Task.CompletedTask;
}
public Task PostConsume<T>(ConsumeContext<T> context) where T : class
{
//use _logger
return Task.CompletedTask;
}
public Task PreConsume<T>(ConsumeContext<T> context) where T : class
{
//use _logger
return Task.CompletedTask;
}
}然后连接你的观察者：
busControl.ConnectConsumeObserver(consumeObserver);页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/39706284
复制相关文章
相似问题