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(); diff --git a/security/RIGHTS.php b/security/RIGHTS.php index 2e6d162..0c0c874 100644 --- a/security/RIGHTS.php +++ b/security/RIGHTS.php @@ -19,6 +19,8 @@ class RIGHTS { const SYS_SAI_CRON = 25; + const SYS_SAI_CRON = 25; + //Reserve first 1000 ids. const RESERVED_SYS_0_999 = 999; } \ No newline at end of file