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 DbFetcher *	m_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:

• DbFetcher.h
• DbFetcher.cpp