|
@@ -41,8 +41,9 @@ class MqConsumer extends ConsumerMessage
|
|
|
$lockAcquired = $redis->setnx($lockKey, $lockValue);
|
|
$lockAcquired = $redis->setnx($lockKey, $lockValue);
|
|
|
if (!$lockAcquired) {
|
|
if (!$lockAcquired) {
|
|
|
$this->logger->info('Another consumer instance is already running.');
|
|
$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;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 设置锁过期时间，防止死锁
|
|
// 设置锁过期时间，防止死锁
|
AI