From b484b5f261405da9735f8a03d6d12d1ed25a51b3 Mon Sep 17 00:00:00 2001 From: aynsix Date: Thu, 14 May 2020 09:51:10 +0300 Subject: [PATCH] fix handler --- lib/Alchemy/Phrasea/WorkerManager/Queue/MessageHandler.php | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/Alchemy/Phrasea/WorkerManager/Queue/MessageHandler.php b/lib/Alchemy/Phrasea/WorkerManager/Queue/MessageHandler.php index b418bc9cbe..b06bbab265 100644 --- a/lib/Alchemy/Phrasea/WorkerManager/Queue/MessageHandler.php +++ b/lib/Alchemy/Phrasea/WorkerManager/Queue/MessageHandler.php @@ -31,6 +31,8 @@ class MessageHandler return ; } + $serverConnection->declareExchange(); + // define consume callbacks $callback = function (AMQPMessage $message) use ($channel, $workerInvoker, $publisher) {