Connectivity_SessionInterface.h

Go to the documentation of this file.

#ifndef _SESSION_INTERFACE_H_
#define _SESSION_INTERFACE_H_


#if defined(_APBUILD_WIN32_ALL__) || defined(__WIN32__) || defined(WIN32)
#define DLLEXPORT __declspec(dllexport)
#elif defined(_APBUILD_UNIX_ALL__) || defined(__unix__)
#define DLLEXPORT
#endif


#include <string>
#include <CUtil.h>
#include "Connectivity_SessionDefs.h"

namespace com {
    namespace apama {
        namespace session {

            class DLLEXPORT SessionInterface
            {
            public:

                SessionInterface(Logger& logger);

                virtual ~SessionInterface() {};

                virtual void setHostSide(HostSide* hostSide);

                void setChainName(const std::string& chainName);

                void setSessionName(const std::string& sessionName);

                void setChannelName(const std::string& channelName);

                void setDescription(const std::string& description);

                virtual void AddSessionParams(SessionParam& param);

                virtual void AddCapabilities(Capability& capability);

                SessionConfigs& getSessionConfiguration();

                virtual void SetSessionState(AP_SESSION_State state, bool generateNewId);

                virtual AP_SESSION_State getSessionState();

                virtual void onSessionStart(int64_t sourceId, map_t& configParams) = 0;

                virtual void onSessionStop(int64_t sourceId) = 0;

                virtual void onSessionReconfigure(int64_t sourceId, map_t& configParams) = 0;
                
                virtual void onSessionRegistrationSuccess(const std::string& sessionName, int64_t sourceId) = 0;
                
                virtual void onSessionRegistrationError(const std::string& sessionName) = 0;

            private:
                Logger logger_;
                SessionConfigs sessionConfigs_;
                CapabilityParams capabilityParams_;
                HostSide* hostSide_;
                std::string loggerPrefix_;
            };
        }
    }
}

#endif