refactor(health): 更新 message.sent 消费者注释 — last_message_at 已在 CAS 中处理
This commit is contained in:
@@ -110,7 +110,7 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) {
|
||||
}
|
||||
});
|
||||
|
||||
// message.sent → 通用消息事件消费者(预留咨询联动)
|
||||
// message.sent → 通用消息事件消费者(预留扩展)
|
||||
let (mut msg_rx, _msg_handle) = state.event_bus.subscribe_filtered("message.".to_string());
|
||||
let _msg_db = state.db.clone();
|
||||
tokio::spawn(async move {
|
||||
@@ -125,8 +125,9 @@ pub fn register_handlers_with_state(state: crate::state::HealthState) {
|
||||
recipient_id = ?recipient_id,
|
||||
"message.sent 消费者收到事件"
|
||||
);
|
||||
// TODO: 若 message 关联了 consultation session(通过 metadata 或 reference),
|
||||
// 可在此更新 consultation_session.last_message_at
|
||||
// 注:consultation_session.last_message_at 已在
|
||||
// consultation_service::create_message() 的 CAS 操作中直接更新,
|
||||
// 无需通过此消费者重复处理
|
||||
}
|
||||
Some(_) => {}
|
||||
None => break,
|
||||
|
||||
Reference in New Issue
Block a user