消费者的生命周期是什么?
What is the life cycle of consumers?
消息消费者是只在总线启动时创建一次,还是每次在端点出现相应类型的消息时创建?
我是说这种订阅消息的方法:
cfg.ReceiveEndpoint(host, "customer_update_queue", e =>
{
e.Consumer<UpdateCustomerConsumer>();
});
为端点上收到的每条消息创建一个新的消费者实例。一旦消息被消费,消费者实例就会被释放(如果它是 IDisposable,也会被释放)。
消息消费者是只在总线启动时创建一次,还是每次在端点出现相应类型的消息时创建?
我是说这种订阅消息的方法:
cfg.ReceiveEndpoint(host, "customer_update_queue", e =>
{
e.Consumer<UpdateCustomerConsumer>();
});
为端点上收到的每条消息创建一个新的消费者实例。一旦消息被消费,消费者实例就会被释放(如果它是 IDisposable,也会被释放)。