diff --git a/db/connection/ConnectionAMQP.php b/db/connection/ConnectionAMQP.php
index 41aef29..99d9784 100644
--- a/db/connection/ConnectionAMQP.php
+++ b/db/connection/ConnectionAMQP.php
@@ -28,12 +28,14 @@ class ConnectionAMQP extends ConnectionAbstr {
         $exchange->setFlags(AMQP_DURABLE);
         $exchange->setName('exchange2');
         $exchange->setType('direct');
-        $exchange->declare();
+        //$exchange->declare();
+        $exchange->declareExchange();
         
         $queue   = new \AMQPQueue($channel);
         $queue->setName('series');
         $queue->setFlags(AMQP_DURABLE | AMQP_AUTODELETE);
-        $queue->declare();
+        //$queue->declare();
+        $queue->declareQueue();
         $queue->bind('exchange2','series');
         
         $channel->startTransaction();