fintp_eventswatcher
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
Public Types | Public Member Functions | Static Public Member Functions | Static Public Attributes | Private Member Functions | Static Private Member Functions | Private Attributes | Static Private Attributes | List of all members
EventsWatcher Class Reference

#include <EventsWatcher.h>

Inheritance diagram for EventsWatcher:
Inheritance graph
[legend]

Public Types

typedef map< string, Service > ServiceMap
 

Public Member Functions

 ~EventsWatcher ()
 
void Start ()
 
void Stop ()
 
void Process (const string &messageId, const unsigned long messageLength)
 
pthread_t getPublisherThreadId () const
 
pthread_t getHBThreadId () const
 
bool isRunning () const
 

Static Public Member Functions

static EventsWatcher * getInstance (const string &configFile="")
 
static void UpdateServiceState (const string &sessionId, const Service::SERVICE_STATE newState, const string &serviceName="")
 
static void * HeartbeatMonitor (void *data)
 
static ServiceMap * getConnectorStateMap ()
 

Static Public Attributes

static pthread_mutex_t StatusSyncMutex = PTHREAD_MUTEX_INITIALIZER
 

Private Member Functions

 EventsWatcher (const string &configFile)
 
void internalStart (void)
 
void UploadMessage (AppException &ex)
 
long getServiceId (const string &sessionId) const
 

Static Private Member Functions

static void * StartInNewThread (void *pThis)
 

Private Attributes

pthread_t m_SelfThreadId
 
MqWatcher m_Watcher
 
AbstractWatcher::NotificationPool m_NotificationPool
 
string m_SessionId
 
TransportHelper * m_CurrentHelper
 
TransportHelper::TRANSPORT_HELPER_TYPE m_HelperType
 
pthread_t m_MonitorThreadId
 
string m_WatchQueue
 
string m_WatchQueueManager
 
string m_TransportURI
 
ServiceMap m_ConnectorState
 

Static Private Attributes

static EventsWatcher * m_Instance = NULL
 
static bool ShouldStop = true
 

Member Typedef Documentation

typedef map< string, Service > EventsWatcher::ServiceMap

Constructor & Destructor Documentation

EventsWatcher::~EventsWatcher ( )
EventsWatcher::EventsWatcher ( const string &  configFile)
private

Member Function Documentation

static ServiceMap* EventsWatcher::getConnectorStateMap ( )
inlinestatic
pthread_t EventsWatcher::getHBThreadId ( ) const
inline
EventsWatcher * EventsWatcher::getInstance ( const string &  configFile = "")
static
pthread_t EventsWatcher::getPublisherThreadId ( ) const
inline
long EventsWatcher::getServiceId ( const string &  sessionId) const
private
void * EventsWatcher::HeartbeatMonitor ( void *  data)
static
void EventsWatcher::internalStart ( void  )
private
bool EventsWatcher::isRunning ( ) const
inline
void EventsWatcher::Process ( const string &  messageId,
const unsigned long  messageLength 
)
void EventsWatcher::Start ( )
void * EventsWatcher::StartInNewThread ( void *  pThis)
staticprivate
void EventsWatcher::Stop ( )
void EventsWatcher::UpdateServiceState ( const string &  sessionId,
const Service::SERVICE_STATE  newState,
const string &  serviceName = "" 
)
static
void EventsWatcher::UploadMessage ( AppException &  ex)
private

Member Data Documentation

ServiceMap EventsWatcher::m_ConnectorState
private
TransportHelper* EventsWatcher::m_CurrentHelper
private
TransportHelper::TRANSPORT_HELPER_TYPE EventsWatcher::m_HelperType
private
EventsWatcher * EventsWatcher::m_Instance = NULL
staticprivate
pthread_t EventsWatcher::m_MonitorThreadId
private
AbstractWatcher::NotificationPool EventsWatcher::m_NotificationPool
private
pthread_t EventsWatcher::m_SelfThreadId
private
string EventsWatcher::m_SessionId
private
string EventsWatcher::m_TransportURI
private
MqWatcher EventsWatcher::m_Watcher
private
string EventsWatcher::m_WatchQueue
private
string EventsWatcher::m_WatchQueueManager
private
bool EventsWatcher::ShouldStop = true
staticprivate
pthread_mutex_t EventsWatcher::StatusSyncMutex = PTHREAD_MUTEX_INITIALIZER
static
The documentation for this class was generated from the following files: