mirror of
https://github.com/EDCD/EDDN.git
synced 2025-04-22 19:40:30 +03:00
49 lines
977 B
PHP
49 lines
977 B
PHP
<?php
|
|
/**
|
|
* Configuration
|
|
*/
|
|
$relayEDDN = 'tcp://eddn.edcd.io:9500';
|
|
$timeoutEDDN = 600000;
|
|
|
|
|
|
|
|
/**
|
|
* START
|
|
*/
|
|
$context = new ZMQContext();
|
|
$subscriber = $context->getSocket(ZMQ::SOCKET_SUB);
|
|
|
|
$subscriber->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, "");
|
|
$subscriber->setSockOpt(ZMQ::SOCKOPT_RCVTIMEO, $timeoutEDDN);
|
|
|
|
while (true)
|
|
{
|
|
try
|
|
{
|
|
$subscriber->connect($relayEDDN);
|
|
|
|
while (true)
|
|
{
|
|
$message = $subscriber->recv();
|
|
|
|
if ($message === false)
|
|
{
|
|
$subscriber->disconnect($relayEDDN);
|
|
break;
|
|
}
|
|
|
|
$message = zlib_decode($message);
|
|
$json = $message;
|
|
|
|
fwrite(STDOUT, $json . PHP_EOL);
|
|
}
|
|
}
|
|
catch (ZMQSocketException $e)
|
|
{
|
|
fwrite(STDOUT, 'ZMQSocketException: ' . $e . PHP_EOL);
|
|
sleep(10);
|
|
}
|
|
}
|
|
|
|
// Exit correctly
|
|
exit(0); |