|
|
@@ -32,6 +32,7 @@ class notifyConsumer implements ConsumerInterface
|
|
|
Yii::error("Invalid notify message format: {$msg->body}", 'rabbitmq.notify');
|
|
|
return ConsumerInterface::MSG_REJECT;
|
|
|
}
|
|
|
+ Yii::info("Processing notify message: " . json_encode($data));
|
|
|
Yii::info("Processing notify message: " . json_encode($data), 'rabbitmq.notify');
|
|
|
// 根据通知类型分发处理
|
|
|
$type = $data['type'] ?? null;
|
