communication_manager.cpp 570 B

12345678910111213141516171819
  1. //
  2. // Created by zx on 2023/11/24.
  3. //
  4. #include "communication_manager.h"
  5. Error_manager CommunicationManager::Init(const CommunicationManagerConfig &config) {
  6. if (config.grpc_enable()) {
  7. m_grpc_server = new StreamRpcServer;
  8. m_grpc_server->Listenning(config.grpc_server_ip(), 9876);
  9. }
  10. if (config.rabbitmq_enable()) {
  11. std::string file_path = ETC_PATH PROJECT_NAME + config.rabbitmq_config_file();
  12. RabbitmqCommunicationTof3D::get_instance_pointer()->rabbitmq_init_from_protobuf(file_path);
  13. }
  14. return Error_manager();
  15. }