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

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

Abort()DbPublishervirtual
Commit()DbPublishervirtual
DbPublisher()DbPublisher
Endpoint()Endpointprotected
getBatchManager()Endpointinline
getDad(const string &dadFilename)DbPublisherprivate
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()DbPublisherinlinevirtual
haveGlobalSetting(const EndpointConfig::ConfigDirection prefix, const EndpointConfig::ConfigSettings setting) const Endpointprotected
Init()DbPublishervirtual
internalStart()DbPublisherprotectedvirtual
internalStop()DbPublisherprotectedvirtual
m_AckDadFileNameDbPublisherprivate
m_BackoutCountEndpointprotected
m_BatchChangedDbPublisherprivate
m_BatchManagerEndpointprotected
m_BlobFilePatternDbPublisherprivate
m_BlobLocatorDbPublisherprivate
m_CfgDatabaseNameDbPublisherprivate
m_CfgUserNameDbPublisherprivate
m_CfgUserPasswordDbPublisherprivate
m_CorrelationIdEndpointprotected
m_CrtBatchItemEndpointprotected
m_CurrentDatabaseDbPublisherprivate
m_CurrentGroupIdDbPublisherprivate
m_CurrentMessageIdDbPublisherprivate
m_CurrentMessageLengthDbPublisherprivate
m_CurrentProviderDbPublisherprivate
m_CurrentStageEndpointprotected
m_DadDbPublisherprivate
m_DadCacheDbPublisherprivate
m_DadOptionsDbPublisherprivate
m_DatabaseNameDbPublisherprivate
m_DatabaseProviderDbPublisherprivate
m_DDSettingsDbPublisherprivate
m_FilterChainEndpointprotected
m_InsertBlobDbPublisherprivate
m_IsLastEndpointprotected
m_LastFailureCorrelationIdEndpointprotected
m_LastOpSucceededEndpointprotected
m_LastRequestorDbPublisherprivate
m_ManagementCallbackEndpointprotectedstatic
m_NotificationPoolEndpointprotected
m_PersistenceFacilityEndpointprotected
m_PrevBatchItemDbPublisherprivate
m_RepliesTableNameDbPublisherprivate
m_RunningEndpointprotected
m_SelfThreadIdEndpointprotected
m_ServiceNameEndpointprotected
m_ServiceThreadIdEndpointprotected
m_SPinsertXmlDataDbPublisherprivate
m_TableNameDbPublisherprivate
m_TrackingDataEndpointprotected
m_TrackMessagesEndpointprotected
m_TransactionKeyEndpointprotected
m_TransactionStartedDbPublisherprivate
m_TransportHeadersEndpointprotected
m_UserNameDbPublisherprivate
m_UserPasswordDbPublisherprivate
m_WatcherDbPublisherprivate
m_WatchQueueDbPublisherprivate
m_WatchQueueManagerDbPublisherprivate
m_WatchTransportURIDbPublisherprivate
m_WMQBatchFilterDbPublisherprivate
m_XmlDataEndpointprotected
moreMessages() const DbPublisherinlinevirtual
PerformMessageLoop()Endpoint
PerformMessageLoop(bool inBatch)Endpoint
Prepare()DbPublishervirtual
Process(const string &correlationId)DbPublishervirtual
Rollback()DbPublishervirtual
SaveBlobToFile(const string &xmlData)DbPublisherprivate
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
UploadMessage(const string &theDadFileName, const string &xmlData, const string &xmlTable, const string &hash)DbPublisherprivate
~DbPublisher()DbPublisher
~Endpoint()Endpointvirtual