SubscriptionManager.h

#ifndef __SubscriptionManager_h__
#define __SubscriptionManager_h__
 
#include "TCPSession.h"
#include "Subscription.h"
#include "Command.h"
#include "ZString.h"
#include <vector>
#include <string>
 
namespace core {
 
   class SubscriptionManager : public Command {
 
    public:
      SubscriptionManager();
        
        int add(Subscription &subscription);
 
      int removeSessionSubscriptions(TCPSession &session);
 
      int processCommand(coreutils::ZString &request, TCPSession &session) override;
 
    private:
      std::map<std::string, Subscription *> subscriptions;
        std::mutex lock;
        
   };
}
 
#endif