NServiceBus消息拦截？

发布于 2024-09-26 14:54:49 字数 766 浏览 1 评论 0原文

有没有办法拦截NServiceBus中的消息？

从现在开始，我可以通过引入基本消息处理程序来手动完成此操作，如下所示：

public abstract class MessageHandler<T> : IHandleMessages<T>
    where T : IMessage
{
    public IBus Bus { get; set; }

    protected abstract void HandleCommand(T command);

    public void Handle(T command)
    {
        // perform some logic on *command* before
        HandleCommand(command);
        // perform some logic on *command* after
    }
}

和用法：

public class ConcreteMessageHandler : MessageHandler<ConcreteMessage>
{
    protected override void HandleCommand(ConcreteMessage message)
    {
        //handle command
    }
}

但是这样做我失去了订阅多个消息的能力（因为我无法从多个 MessageHandler 继承代码>类）。

原文

Is there any way to intercept messages in NServiceBus?

From now i can do it manually via introducing base message handler like this:

public abstract class MessageHandler<T> : IHandleMessages<T>
    where T : IMessage
{
    public IBus Bus { get; set; }

    protected abstract void HandleCommand(T command);

    public void Handle(T command)
    {
        // perform some logic on *command* before
        HandleCommand(command);
        // perform some logic on *command* after
    }
}

And the usage:

public class ConcreteMessageHandler : MessageHandler<ConcreteMessage>
{
    protected override void HandleCommand(ConcreteMessage message)
    {
        //handle command
    }
}

But doing this way i'm loosing an ability to subscribe to multiple messages (because i cannot inherit from multiple MessageHandler<> classes).

分享到QQ

分享到微博