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

Merge branch 'master' of github.com:gebhardtdasense/system

Browse Source
This commit is contained in:
Ulf Gebhardt 2014-10-13 17:41:53 +02:00
commit b42176ed8a
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();