-fix silly mistake after refactoring

again
This commit is contained in:
Martin Konecny 2012-09-11 11:20:42 -04:00
parent 41d9b2490a
commit a06eeaa76a
1 changed files with 2 additions and 3 deletions

View File

@ -26,12 +26,11 @@ class Application_Model_RabbitMq
$channel->access_request($CC_CONFIG["rabbitmq"]["vhost"], false, false, $channel->access_request($CC_CONFIG["rabbitmq"]["vhost"], false, false,
true, true); true, true);
$EXCHANGE = 'airtime-pypo'; $channel->exchange_declare($exchange, 'direct', false, true);
$channel->exchange_declare($EXCHANGE, 'direct', false, true);
$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);
$channel->close(); $channel->close();
$conn->close(); $conn->close();
} }