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