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) {