在迁移到Masstrasit8.0.3之后,ScopeFilter确实允许响应并结束发送中的使用者进程(ConsumeContext.)方法。在我们的例子中,我们有一个带有中介设置的缓存作用域过滤器。在消费发送方法中有一个CacheScopeFilter,它检查特定请求是否在内存缓存中:
var cacheResponse = cacheService.GetCachedResponse在Masstransit<
这是我第一次在Java中创建一个多线程应用程序,该应用程序将持续运行直到被取消,并且我在关闭/中断我的线程时遇到了困难。我使用这个中介程序而不是未来,因为TransferQueue对于单个用户处理多个生产者(生产者线程可以在任何时候都可以使用mediator.put( be ),并且消费者线程可以等待be= mediator.take该设计非常干净、快速