webcraftmedia/system
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed amqp connection.

Browse Source
This commit is contained in:
Ulf Gebhardt 2014-06-24 14:05:53 +02:00
parent d368226d14
commit 9582630107
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
db/connection/ConnectionAMQP.php
View File

@ -28,12 +28,14 @@ class ConnectionAMQP extends ConnectionAbstr {
$exchange->setFlags(AMQP_DURABLE); $exchange->setFlags(AMQP_DURABLE);
$exchange->setName('exchange2'); $exchange->setName('exchange2');
$exchange->setType('direct'); $exchange->setType('direct');
$exchange->declare(); //$exchange->declare();
$exchange->declareExchange();
$queue = new \AMQPQueue($channel); $queue = new \AMQPQueue($channel);
$queue->setName('series'); $queue->setName('series');
$queue->setFlags(AMQP_DURABLE | AMQP_AUTODELETE); $queue->setFlags(AMQP_DURABLE | AMQP_AUTODELETE);
$queue->declare(); //$queue->declare();
$queue->declareQueue();
$queue->bind('exchange2','series'); $queue->bind('exchange2','series');
$channel->startTransaction(); $channel->startTransaction();