From 3ff0c017db5a0cdc98da0e4671564c31443f37e6 Mon Sep 17 00:00:00 2001 From: Pavel Dmitriev Date: Thu, 26 Jan 2023 13:08:14 +0300 Subject: [PATCH] added default routing tag --- barcodeScanner.php | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/barcodeScanner.php b/barcodeScanner.php index af8b168..43330f3 100644 --- a/barcodeScanner.php +++ b/barcodeScanner.php @@ -15,9 +15,8 @@ $rabbitLogin=getenv("RABBITMQ_USER"); $rabbitPass=getenv("RABBITMQ_PASSWORD"); $rabbitUseSSL=getenv("RABBITMQ_USE_SSL")==="true"; $rabbitVirtualHost=getenv("RABBITMQ_VIRTUAL_HOST")?getenv("RABBITMQ_VIRTUAL_HOST"):"/"; +$routingTag=getenv("DEFAULT_TAG")?getenv("DEFAULT_TAG"):null; - -$routingTag=null; $connection=null; $channel=null; @@ -54,6 +53,14 @@ function rabbitConnect($rabbitHost, $rabbitPort, $rabbitLogin, $rabbitPass, $rab return $connection; } +function register($channel, $routingTag) { + print "Register\n"; + if (!empty($routingTag)) { + $msg = new AMQPMessage(json_encode(["type"=>"service","data"=>"register"])); + $channel->basic_publish($msg, 'fox.barcode', $routingTag); + } +} + function scanner($channel, $port) { global $routingTag; @@ -68,6 +75,7 @@ function scanner($channel, $port) { } } + while (1) { $buffer = fgets($fp, 4096); $rv=explode("\n", $buffer);