src/pubsub_center.h
@@ -36,9 +36,11 @@ }; SocketBus socket_; ShmSocket::Shm &shm() { return socket_.shm(); } std::mutex mutex_; typedef std::set<MQId> Clients; std::unordered_map<std::string, Clients> records_; std::unordered_map<Topic, Clients> records_; bool Find1(const Topic &topic); public: PubSubCenter(ShmSocket::Shm &shm) :
