#include <DbFetcher.h>
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 |
DbFetcher::DbFetcher | ( | ) |
DbFetcher::~DbFetcher | ( | ) |
|
virtual |
Aborts the work and rolls back the data
Implements Endpoint.
|
virtual |
Commits the work
Implements Endpoint.
|
inlinevirtual |
Implements Endpoint.
|
virtual |
Implements Endpoint.
|
protectedvirtual |
Implements Endpoint.
|
protectedvirtual |
Implements Endpoint.
|
static |
|
virtual |
Make an engagement whether it can/can't process the data
Implements Endpoint.
|
virtual |
|
virtual |
Rollback
Implements Endpoint.
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
static |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |