d38e2adb58
This is the code for the server side to push the schedule to RabbitMQ. Right now it is disabled and should cause no changes in behavior. Also added comments to functions and formatted code correctly.
33 lines
1.1 KiB
PHP
33 lines
1.1 KiB
PHP
<?php
|
|
require_once 'php-amqplib/amqp.inc';
|
|
|
|
class RabbitMq
|
|
{
|
|
|
|
/**
|
|
* Push the current schedule to RabbitMQ, to be picked up by Pypo.
|
|
* Will push the schedule in the range from 24 hours ago to 24 hours
|
|
* in the future.
|
|
*/
|
|
public static function PushSchedule() {
|
|
// global $CC_CONFIG;
|
|
// $conn = new AMQPConnection($CC_CONFIG["rabbitmq"]["host"],
|
|
// $CC_CONFIG["rabbitmq"]["port"],
|
|
// $CC_CONFIG["rabbitmq"]["user"],
|
|
// $CC_CONFIG["rabbitmq"]["password"]);
|
|
// $channel = $conn->channel();
|
|
// $channel->access_request($CC_CONFIG["rabbitmq"]["vhost"], false, false, true, true);
|
|
//
|
|
// $EXCHANGE = 'airtime-schedule';
|
|
// $channel->exchange_declare($EXCHANGE, 'direct', false, false, false);
|
|
//
|
|
// $data = json_encode(Schedule::ExportRangeAsJson());
|
|
// $msg = new AMQPMessage($data, array('content_type' => 'text/plain'));
|
|
//
|
|
// $channel->basic_publish($msg, $EXCHANGE);
|
|
// $channel->close();
|
|
// $conn->close();
|
|
}
|
|
|
|
}
|
|
|