//消息订阅者
#ifndef RUMsgSubscriber_h
#define RUMsgSubscriber_h

#include "RUDefine.h"
#include "RUMsg.h"

NS_RU_BEGIN
class RUMsgCenter;
class MsgSubscriber
{
public:
    MsgSubscriber() = default;
    ~MsgSubscriber() = default;
    virtual void subscribe(std::string key4MsgCenter, kMsgTopic msgTopic, int priority = 0);
    virtual void unsubscribe(std::string key4MsgCenter, kMsgTopic msgTopic);
    virtual void handleMsg(Msg* msg) = 0;
    
    virtual void setPriority(kMsgTopic msgTopic, int priority);
    virtual int getPriority(kMsgTopic msgTopic);
private:
    std::unordered_map<int, int> _priorityMap;
};

NS_RU_END

#endif /* MsgSubscriber_h */