|
@@ -203,7 +203,7 @@ class RouteRfidKafkaAction extends Action {
|
|
|
$e = oci_error();
|
|
|
trigger_error(htmlentities($e['message'], ENT_QUOTES), E_USER_ERROR);
|
|
|
}
|
|
|
- echo 11111;
|
|
|
+
|
|
|
while (true) {
|
|
|
//var_dump($conn);
|
|
|
$message = $consumer->consume(120*1000);
|
|
@@ -718,7 +718,7 @@ class RouteRfidKafkaAction extends Action {
|
|
|
$e = oci_error();
|
|
|
trigger_error(htmlentities($e['message'], ENT_QUOTES), E_USER_ERROR);
|
|
|
}
|
|
|
- echo 11111;
|
|
|
+
|
|
|
while (true) {
|
|
|
//var_dump($conn);
|
|
|
$message = $consumer->consume(120*1000);
|