Connectivity_SessionManager.h

Go to the documentation of this file.

 
#ifndef _SESSION_MANAGER_H_
#define _SESSION_MANAGER_H_
 
#include "Connectivity_SessionInterface.h"
 
namespace com {
    namespace apama {
        namespace session {
 
            class DLLEXPORT SessionManager {
            public:
                SessionManager
                (
                    Logger& logger
                ) :
                    logger_(logger)
                {
                };
                virtual ~SessionManager() {};
 
 
                virtual void setHostSide(HostSide* hostSideptr) = 0;
 
                virtual void addSession(const std::string& chainName, const std::string& sessionName,
                    const std::string& description, SessionInterface *sessionHandler) = 0;
 
                virtual void RegisterSessions(int interval = 5) = 0;
 
                virtual void RegisterSession(const std::string& sessionName) = 0;
 
                virtual bool HasCapability(const std::string& sessionName, const std::string& capability) = 0;
 
                virtual void DeleteSessionByName(const std::string& sessionName) = 0;
 
                virtual void DeleteSessionById(int64_t sourceId) = 0;
 
                virtual int64_t getSessionId(const std::string& sessionName) = 0;
 
                virtual std::string getSessionName(int64_t sessionId) = 0;
 
                virtual void Start() = 0;
 
                virtual void Stop() = 0;
 
                virtual void Clear() = 0;
 
                virtual void SetSessionStateByName(const std::string& sessionName, AP_SESSION_State state, bool generateNewId = false) = 0;
 
                virtual void SetSessionStateById(int64_t sourceId, AP_SESSION_State state, bool usePreviousGenerationId = false) = 0;
 
 
                virtual AP_SESSION_State GetSessionStateByName(const std::string& sessionName) = 0;
 
 
                virtual AP_SESSION_State GetSessionStateById(int64_t sourceId) = 0;
 
                virtual void SessionStartSuccess(int64_t sourceId) = 0;
 
                virtual void SessionStartError(int64_t sourceId, const std::string& errMsg) = 0;
 
                virtual void SessionStopSuccess(int64_t sourceId) = 0;
 
                virtual void SessionStopError(int64_t sourceId, const std::string& errMsg) = 0;
 
                virtual void SessionReconfigureSuccess(int64_t sourceId) = 0;
 
                virtual void SessionReconfigureError(int64_t sourceId, const std::string& errMsg) = 0;
 
 
                virtual bool ProcessMessage(Message& msg) = 0;
 
            private:
                HostSide* hostSide_;
                Logger logger_;
                SessionInterface* sessionHandlerIface_;
            };
 
            
            class DLLEXPORT SessionManagerFactory {
            public:
 
                static SessionManager* createSessionManager(Logger& logger);
            };
        }
    }
}
 
#endif