fix handler

This commit is contained in:
aynsix
2020-05-14 09:51:10 +03:00
parent daf059d03f
commit b484b5f261

View File

@@ -31,6 +31,8 @@ class MessageHandler
return ;
}
$serverConnection->declareExchange();
// define consume callbacks
$callback = function (AMQPMessage $message) use ($channel, $workerInvoker, $publisher) {