将SendObserver连接到一次consume context获得的ISendEndpoint
Connect SendObserver to ISendEndpoint obtained by consume context once
我正在尝试在 ISendEndpoint 上使用 SendObserver 观察发送的消息。当我从消费上下文中使用 GetSendEndpoint 并使用 ConnectSendObserver 添加观察者时,我注意到从先前消息添加的先前观察者仍然存在,因此在发送第一条消息后会多次调用观察者。
请注意,我必须通过消费上下文设置观察者。
一旦发送的消息被观察到,您应该使用观察者连接时返回的 ConnectHandle
来断开观察者。在您的情况下,一旦 ConsumeContext
不再被使用 - 例如在消费者的末尾。
这样,您就不会随着时间的推移积累它们。
我正在尝试在 ISendEndpoint 上使用 SendObserver 观察发送的消息。当我从消费上下文中使用 GetSendEndpoint 并使用 ConnectSendObserver 添加观察者时,我注意到从先前消息添加的先前观察者仍然存在,因此在发送第一条消息后会多次调用观察者。 请注意,我必须通过消费上下文设置观察者。
一旦发送的消息被观察到,您应该使用观察者连接时返回的 ConnectHandle
来断开观察者。在您的情况下,一旦 ConsumeContext
不再被使用 - 例如在消费者的末尾。
这样,您就不会随着时间的推移积累它们。