communication_manager.h 592 B

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