fintp_connectors
 All Classes Namespaces Files Functions Variables Enumerations Enumerator Macros Pages
DbFetcher Member List

This is the complete list of members for DbFetcher, including all inherited members.

Abort()DbFetchervirtual
Commit()DbFetchervirtual
DbFetcher()DbFetcher
Endpoint()Endpointprotected
getBatchManager()Endpointinline
getFilterChain()Endpointinline
getGlobalSetting(const EndpointConfig::ConfigDirection prefix, const EndpointConfig::ConfigSettings setting, const string &defaultValue="__NODEFAULT") const Endpointprotected
getGlobalSettings() const Endpointprotected
getPersistenceFacility()Endpoint
getServiceName() const Endpointinlineprotected
getThreadId()Endpointinline
getThreadId() const Endpointinline
getWatcherThreadId()DbFetcherinlinevirtual
haveGlobalSetting(const EndpointConfig::ConfigDirection prefix, const EndpointConfig::ConfigSettings setting) const Endpointprotected
Init()DbFetchervirtual
internalStart()DbFetcherprotectedvirtual
internalStop()DbFetcherprotectedvirtual
m_BackoutCountEndpointprotected
m_BatchManagerEndpointprotected
m_CorrelationIdEndpointprotected
m_CrtBatchItemEndpointprotected
m_CurrentDatabaseDbFetcherprivate
m_CurrentMessageDbFetcherprivate
m_CurrentMessageStrDbFetcherprivate
m_CurrentProviderDbFetcherprivate
m_CurrentRowIdDbFetcherprivate
m_CurrentStageEndpointprotected
m_DatabaseNameDbFetcherprivate
m_DatabaseProviderDbFetcherprivate
m_DatabaseToXmlTrimmDbFetcherprivate
m_FilterChainEndpointprotected
m_IsLastEndpointprotected
m_LastFailureCorrelationIdEndpointprotected
m_LastOpSucceededEndpointprotected
m_ManagementCallbackEndpointprotectedstatic
m_MaxUncommitedTrnsDbFetcherprivate
m_MeDbFetcherstatic
m_NotificationPoolEndpointprotected
m_NotificationTypeXMLDbFetcherprivate
m_PersistenceFacilityEndpointprotected
m_RollbackDbFetcherprivate
m_RunningEndpointprotected
m_SavedMessageDbFetcherprivate
m_SelfThreadIdEndpointprotected
m_ServiceNameEndpointprotected
m_ServiceThreadIdEndpointprotected
m_SPmarkabortDbFetcherprivate
m_SPmarkcommitDbFetcherprivate
m_SPmarkforprocessDbFetcherprivate
m_SPselectforprocessDbFetcherprivate
m_SPWatcherDbFetcherprivate
m_TableNameDbFetcherprivate
m_TrackingDataEndpointprotected
m_TrackMessagesEndpointprotected
m_TransactionKeyEndpointprotected
m_TransportHeadersEndpointprotected
m_UncommitedTrnsDbFetcherprivate
m_UserNameDbFetcherprivate
m_UserPasswordDbFetcherprivate
m_WatcherDbFetcherprivate
m_XmlDataEndpointprotected
moreMessages() const Endpointinlinevirtual
NotificationCallback(const AbstractWatcher::NotificationObject *notification)DbFetcherstatic
PerformMessageLoop()Endpoint
PerformMessageLoop(bool inBatch)Endpoint
Prepare()DbFetchervirtual
Process(const string &correlationId)DbFetchervirtual
Rollback()DbFetchervirtual
setCorrelationId(const string &correlationId)Endpointprotected
setGlobalSettings(AppSettings *settings)Endpointinlinestatic
setManagementCallback(void(*callback)(TransactionStatus::TransactionStatusEnum, void *))Endpointinlinestatic
setPersistenceFacility(AbstractStatePersistence *facility)Endpoint
setServiceName(const string &value)Endpointinline
setServiceThreadId(const string &serviceThreadId)Endpointinline
Start()Endpoint
StartInNewThread(void *)Endpointstatic
Stop()Endpoint
trackMessage(const string &payload, const NameValueCollection &transportHeaders)Endpointvirtual
~DbFetcher()DbFetcher
~Endpoint()Endpointvirtual