与工控机通讯数据协议全部更改成PB格式

core/function-impl/mogo-core-function-autopilot/src/main/java/com/mogo/eagle/core/function/autopilot/MoGoAutopilotProvider.kt

@@ -71,7 +71,7 @@ class MoGoAutopilotProvider :
                 .setClient(false)
                 .build()
 
-            AdasManager.getInstance().create(context, options)
+            AdasManager.getInstance().create(options, MoGoAdasMsgConnectStatusListenerImpl())
             NSDNettyManager.getInstance().startNSDNettyServerWithSN(context, object :
                 NettyServerListener<MogoProtocolMsg> {
                 override fun onMessageResponseServer(msg: MogoProtocolMsg?, channel: Channel?) {
@@ -107,7 +107,7 @@ class MoGoAutopilotProvider :
                 .setIpcAssignIP(FunctionBuildConfig.adasConnectIP)
                 .setClient(true)
                 .build()
-            AdasManager.getInstance().create(context, options)
+            AdasManager.getInstance().create(options, MoGoAdasMsgConnectStatusListenerImpl())
             NSDNettyManager.getInstance()
                 .searchAndConnectServer(context, MoGoAiCloudClientConfig.getInstance().sn, object :
                     NettyClientListener<MogoProtocolMsg> {
@@ -134,9 +134,7 @@ class MoGoAutopilotProvider :
                 })
         }
         //////////////////////////////////注意先后顺序，AdasManager.getInstance().create后才可以设置监听/////////////////////////////////////////////
-        // 监听 adas 连接状态
-        AdasManager.getInstance()
-            .setOnAdasConnectStatusListener(MoGoAdasMsgConnectStatusListenerImpl())
+
         // 监听ADAS-SDK获取到的工控机数据(乘客也需注册)
         AdasManager.getInstance().setOnAdasListener(MoGoAdasListenerImpl())
         // 司机端监听