Fixed bug that the process couldn't be restarted caused by loop which using CoordinatorManager. (#3908)

* Fixed bug the consumer restart failed when AMQP server restart.

* Update CHANGELOG-2.2.md
This commit is contained in:
李铭昕 2021-08-05 14:20:33 +08:00 committed by GitHub
parent fecba7a7d9
commit b7bcfa2a3f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions

View File

@ -5,7 +5,8 @@
- [#3897](https://github.com/hyperf/hyperf/pull/3897) Fixed bug that nacos instance will be registered more than once, because heartbeat failed caused by light beat enabled.
- [#3905](https://github.com/hyperf/hyperf/pull/3905) Fixed null pointer exception when closing AMQPConnection.
- [#3906](https://github.com/hyperf/hyperf/pull/3906) Fixed bug that close connection failed caused by wait channels flushed.
-
- [#3908](https://github.com/hyperf/hyperf/pull/3908) Fixed bug that the process couldn't be restarted caused by loop which using `CoordinatorManager`.
# v2.2.2 - 2021-08-03
## Fixed

View File

@ -140,6 +140,7 @@ abstract class AbstractProcess implements ProcessInterface
$quit->push(true);
}
Timer::clearAll();
CoordinatorManager::until(Constants::WORKER_EXIT)->resume();
sleep($this->restartInterval);
}
}, $this->redirectStdinStdout, $this->pipeType, $this->enableCoroutine);