78b33b9e23
Implemented RabbitMQ on the pypo side. Schedule updates are now almost instantaneous and we are only polling the server once per hour if we aren't updated in that time. Canceling a show happens right away.
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, true);
|
|
|
|
$data = json_encode(Schedule::ExportRangeAsJson());
|
|
$msg = new AMQPMessage($data, array('content_type' => 'text/plain'));
|
|
|
|
$channel->basic_publish($msg, $EXCHANGE);
|
|
$channel->close();
|
|
$conn->close();
|
|
}
|
|
|
|
}
|
|
|