diff --git a/www-api/app/Controllers/WrenchHooks.php b/www-api/app/Controllers/WrenchHooks.php index 99efc0a7..3cc806f4 100644 --- a/www-api/app/Controllers/WrenchHooks.php +++ b/www-api/app/Controllers/WrenchHooks.php @@ -41,8 +41,12 @@ class WrenchHooks extends BaseController try { if ( $enable_event_publish == true && !empty($in) ){ + $eventMsg = [ + "message" => serialize($in) + ]; + $local_url = "http://".$this->micro_service_net1.":".$microPort."/flutterOkHook"; - $out = $this->APIcall('POST', $local_url, $in); + $out = $this->APIcall('POST', $local_url, $eventMsg); //kafKa Lane } } catch (Exception $e) { log_message('critical', "WrenchHooks flutter Kafka fail => ".$e->getMessage());