AoP支持NServiceBus？

Question

回到我的老问题here：

但是我真的想拦截消息并拥有处理程序的一个实例，并且能够影响消息是否应该传递给处理程序。基本上是个“周密的建议”。

现在，实现这样的东西的最传统的方法是通过动态继承目标对象和重写虚拟方法。由于缺乏文档，我无法判断是NServiceBus创建了还是构建了它的消息处理程序实例。如果它构建起来了，那么它就不能动态继承，所以大多数AoP框架可能是不可能的，否则最流行的DI容器应该能做到这一点。

然而，使用Saga手进行测试时，由于对默认构造函数的要求，NServiceBus似乎是建立起来而不是创建新的，这意味着NServiceBus手动激活类。

是的，我意识到我可以使用好的ole‘OOP来解决同样的问题，但我通常更喜欢AoP，以获得更好(更少)的耦合。

Answer 1

如果您只想影响消息是否应该转到处理程序，那么NServiceBus为=> DoNotContinueDispatchingCurrentMessageToHandlers()提供了一个解决方案。

您可以创建一个泛型处理程序，并将其设置为在任何其他处理程序之前触发。

public class SomeHandler: IHandleMessages<object>, ISpecifyMessageHandlerOrdering
{
    public IBus Bus {get;set;}

    public void Handle(object message)
    {
        Bus.DoNotContinueDispatchingCurrentMessageToHandlers();
    }

    public void SpecifyOrder(Order order)
    {
        order.SpecifyFirst<SomeHandler>();
    }
}

有关详细信息，请参阅this答案

另外，也可以将其插入到变送器中

class StopThePipelineMutator: IMutateIncomingTransportMessages,INeedInitialization
{
    public IBus Bus { get; set; }

    public void MutateIncoming(TransportMessage transportMessage)
    {
        Bus.DoNotContinueDispatchingCurrentMessageToHandlers();    
    }

    public void Init()
    {
       Configure.Component<StopThePipelineMutator>(DependencyLifecycle.InstancePerCall);
    }
}

Answer 2

以前的帖子，但是有人在寻找一种通过NServiceBus获取AOP的方法，这里有一种不同的方法：

https://github.com/MeTitus/NServiceBus/commit/278b6bf4e3daba2fbdfc5295b8718609946d653d

另一种方法是用户PostSharp。