我在这里可能是错的,但是当我准备好时,我看不出有任何方法可以使用 Masstransit 来消费消息,而只是有一个消费者类,当我们确实有消息要消费时被调用?
有没有办法在请求之前基本上不消耗任何东西?类似于RabbitMQ客户端库如何有basicget?
现在我有这个设置:
public class LoaderConsumer : IConsumer<LoadQueueItemCommand>
{
public Task Consume(ConsumeContext<LoadQueueItemCommand> context)
{
throw new NotImplementedException();
}
}
但是如果在应用程序的另一个区域我依赖它并想在那里使用它怎么办?
MassTransit 仅支持将消息从交通工具“推送”到消费者。 MassTransit 不提供任何方法/接口来从传输中“拉取”消息。