communication_manager.h 623 B

1234567891011121314151617181920212223242526
  1. #include "tool/error_code.hpp"
  2. #include "rabbitmq/rabbitmq_communication.h"
  3. #include "grpc/streamServer.h"
  4. #include "mqtt/mqtt_communication.h"
  5. #include "proto/communication.pb.h"
  6. class CommunicationManager {
  7. public:
  8. static CommunicationManager *iter() {
  9. static CommunicationManager *instance = nullptr;
  10. if (instance == nullptr) {
  11. instance = new CommunicationManager();
  12. }
  13. return instance;
  14. }
  15. ~CommunicationManager() = default;
  16. Error_manager Init(const CommunicationManagerConfig &config);
  17. protected:
  18. private:
  19. StreamRpcServer *m_grpc_server = nullptr;
  20. };