fintp_connectors
 All Classes Namespaces Files Functions Variables Enumerations Enumerator Macros Pages
DbFetcher Class Reference

#include <DbFetcher.h>

Inheritance diagram for DbFetcher:

Public Member Functions

 DbFetcher ()
 
 ~DbFetcher ()
 
void Init ()
 
string Prepare ()
 Make an engagement whether it can/can't process the data More...
 
void Commit ()
 Commits the work More...
 
void Abort ()
 Aborts the work and rolls back the data More...
 
void Rollback ()
 Rollback More...
 
void Process (const string &correlationId)
 Processes the data More...
 
pthread_t getWatcherThreadId ()
 
- Public Member Functions inherited from Endpoint
virtual ~Endpoint ()
 
void Start ()
 
void Stop ()
 
bool PerformMessageLoop ()
 
bool PerformMessageLoop (bool inBatch)
 
virtual bool moreMessages () const
 
virtual void trackMessage (const string &payload, const NameValueCollection &transportHeaders)
 
void setPersistenceFacility (AbstractStatePersistence *facility)
 
AbstractStatePersistence * getPersistenceFacility ()
 
void setServiceName (const string &value)
 
void setServiceThreadId (const string &serviceThreadId)
 
pthread_t getThreadId ()
 
const pthread_t getThreadId () const
 
FilterChain * getFilterChain ()
 
BatchManagerBase * getBatchManager ()
 

Static Public Member Functions

static void NotificationCallback (const AbstractWatcher::NotificationObject *notification)
 
- Static Public Member Functions inherited from Endpoint
static void * StartInNewThread (void *)
 
static void setManagementCallback (void(*callback)(TransactionStatus::TransactionStatusEnum, void *))
 
static void setGlobalSettings (AppSettings *settings)
 

Static Public Attributes

static DbFetcherm_Me = NULL
 

Protected Member Functions

void internalStart ()
 
void internalStop ()
 
- Protected Member Functions inherited from Endpoint
 Endpoint ()
 
string getServiceName () const
 
void setCorrelationId (const string &correlationId)
 
AppSettings & getGlobalSettings () const
 
bool haveGlobalSetting (const EndpointConfig::ConfigDirection prefix, const EndpointConfig::ConfigSettings setting) const
 
string getGlobalSetting (const EndpointConfig::ConfigDirection prefix, const EndpointConfig::ConfigSettings setting, const string &defaultValue="__NODEFAULT") const
 

Private Attributes

DbWatcher m_Watcher
 
string m_CurrentRowId
 
int m_UncommitedTrns
 
int m_MaxUncommitedTrns
 
XERCES_CPP_NAMESPACE_QUALIFIER
DOMDocument * 
m_CurrentMessage
 
XERCES_CPP_NAMESPACE_QUALIFIER
DOMDocument * 
m_SavedMessage
 
ManagedBuffer * m_CurrentMessageStr
 
bool m_NotificationTypeXML
 
bool m_Rollback
 
bool m_DatabaseToXmlTrimm
 
string m_DatabaseProvider
 
string m_DatabaseName
 
string m_UserName
 
string m_UserPassword
 
string m_TableName
 
string m_SPmarkforprocess
 
string m_SPselectforprocess
 
string m_SPmarkcommit
 
string m_SPmarkabort
 
string m_SPWatcher
 
Database * m_CurrentDatabase
 
DatabaseProviderFactory * m_CurrentProvider
 

Additional Inherited Members

- Protected Attributes inherited from Endpoint
BatchManagerBase * m_BatchManager
 
AbstractStatePersistence * m_PersistenceFacility
 
unsigned int m_BackoutCount
 
unsigned int m_CurrentStage
 
unsigned int m_CrtBatchItem
 
string m_ServiceName
 
string m_ServiceThreadId
 
string m_CorrelationId
 
string m_LastFailureCorrelationId
 
string m_TransactionKey
 
pthread_t m_SelfThreadId
 
bool m_Running
 
bool m_LastOpSucceeded
 
AbstractWatcher::NotificationPool m_NotificationPool
 
NameValueCollection m_TransportHeaders
 
string m_XmlData
 
AppException m_TrackingData
 
bool m_IsLast
 
bool m_TrackMessages
 
FilterChain * m_FilterChain
 
- Static Protected Attributes inherited from Endpoint
static void(* m_ManagementCallback )(TransactionStatus::TransactionStatusEnum, void *additionalData) = NULL
 

Constructor & Destructor Documentation

DbFetcher::DbFetcher ( )
DbFetcher::~DbFetcher ( )

Member Function Documentation

void DbFetcher::Abort ( )
virtual

Aborts the work and rolls back the data

Implements Endpoint.

void DbFetcher::Commit ( )
virtual

Commits the work

Implements Endpoint.

pthread_t DbFetcher::getWatcherThreadId ( )
inlinevirtual

Implements Endpoint.

void DbFetcher::Init ( )
virtual

Implements Endpoint.

void DbFetcher::internalStart ( )
protectedvirtual

Implements Endpoint.

void DbFetcher::internalStop ( )
protectedvirtual

Implements Endpoint.

void DbFetcher::NotificationCallback ( const AbstractWatcher::NotificationObject *  notification)
static
string DbFetcher::Prepare ( )
virtual

Make an engagement whether it can/can't process the data

Returns
True if it can process the data

Implements Endpoint.

void DbFetcher::Process ( const string &  correlationId)
virtual

Processes the data

Returns
True if everything worked fine

Implements Endpoint.

void DbFetcher::Rollback ( )
virtual

Rollback

Implements Endpoint.

Member Data Documentation

Database* DbFetcher::m_CurrentDatabase
private
XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument* DbFetcher::m_CurrentMessage
private
ManagedBuffer* DbFetcher::m_CurrentMessageStr
private
DatabaseProviderFactory* DbFetcher::m_CurrentProvider
private
string DbFetcher::m_CurrentRowId
private
string DbFetcher::m_DatabaseName
private
string DbFetcher::m_DatabaseProvider
private
bool DbFetcher::m_DatabaseToXmlTrimm
private
int DbFetcher::m_MaxUncommitedTrns
private
DbFetcher * DbFetcher::m_Me = NULL
static
bool DbFetcher::m_NotificationTypeXML
private
bool DbFetcher::m_Rollback
private
XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument* DbFetcher::m_SavedMessage
private
string DbFetcher::m_SPmarkabort
private
string DbFetcher::m_SPmarkcommit
private
string DbFetcher::m_SPmarkforprocess
private
string DbFetcher::m_SPselectforprocess
private
string DbFetcher::m_SPWatcher
private
string DbFetcher::m_TableName
private
int DbFetcher::m_UncommitedTrns
private
string DbFetcher::m_UserName
private
string DbFetcher::m_UserPassword
private
DbWatcher DbFetcher::m_Watcher
private

The documentation for this class was generated from the following files: