|
|
@@ -41,8 +41,9 @@ class MqConsumer extends ConsumerMessage
|
|
|
$lockAcquired = $redis->setnx($lockKey, $lockValue);
|
|
|
if (!$lockAcquired) {
|
|
|
$this->logger->info('Another consumer instance is already running.');
|
|
|
- var_dump($redis->get($lockKey));
|
|
|
- return Result::ACK;
|
|
|
+ $this->logger->info($redis->get($lockKey));
|
|
|
+ // return Result::ACK;
|
|
|
+ return Result::REQUEUE;
|
|
|
}
|
|
|
|
|
|
// 设置锁过期时间，防止死锁
|
|
|
@@ -50,6 +51,7 @@ class MqConsumer extends ConsumerMessage
|
|
|
try {
|
|
|
// 数据存储
|
|
|
$this->logger->info('消费数据', ['data' => $data]);
|
|
|
+ var_dump($data, '=================消费数据==============');
|
|
|
// 调用数据处理服务
|
|
|
$result = $this->chatServiceClient->addChatRecords($data);
|
|
|
// 记录处理结果
|
AI