-fix silly mistake after refactoring
This commit is contained in:
parent
6c54605327
commit
41d9b2490a
|
@ -29,7 +29,6 @@ class Application_Model_RabbitMq
|
||||||
$EXCHANGE = 'airtime-pypo';
|
$EXCHANGE = 'airtime-pypo';
|
||||||
$channel->exchange_declare($EXCHANGE, 'direct', false, true);
|
$channel->exchange_declare($EXCHANGE, 'direct', false, true);
|
||||||
|
|
||||||
$data = json_encode($md, JSON_FORCE_OBJECT);
|
|
||||||
$msg = new AMQPMessage($data, array('content_type' => 'text/plain'));
|
$msg = new AMQPMessage($data, array('content_type' => 'text/plain'));
|
||||||
|
|
||||||
$channel->basic_publish($msg, $EXCHANGE);
|
$channel->basic_publish($msg, $EXCHANGE);
|
||||||
|
|
Loading…
Reference in New Issue