#include <DbPublisher.h>

Inheritance diagram for DbPublisher:

Public Member Functions
	DbPublisher ()

	~DbPublisher ()

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 ()

bool	moreMessages () const

Public Member Functions inherited from Endpoint
virtual	~Endpoint ()

void	Start ()

void	Stop ()

bool	PerformMessageLoop ()

bool	PerformMessageLoop (bool inBatch)

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 ()

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 Member Functions
string	getDad (const string &dadFilename)

void	UploadMessage (const string &theDadFileName, const string &xmlData, const string &xmlTable, const string &hash)

string	SaveBlobToFile (const string &xmlData)

Private Attributes
ConnectorsDDInfo	m_DDSettings

MqWatcher	m_Watcher

string	m_WatchQueue

string	m_WatchQueueManager

string	m_WatchTransportURI

bool	m_WMQBatchFilter

string	m_CfgDatabaseName

string	m_CfgUserName

string	m_CfgUserPassword

string	m_BlobLocator

string	m_BlobFilePattern

bool	m_InsertBlob

string	m_DatabaseProvider

string	m_DatabaseName

string	m_TableName

string	m_RepliesTableName

string	m_UserName

string	m_UserPassword

DbDad::DadOptions	m_DadOptions

string	m_AckDadFileName

string	m_SPinsertXmlData

string	m_CurrentMessageId

string	m_CurrentGroupId

unsigned long	m_CurrentMessageLength

CacheManager< string, string >	m_DadCache

Database *	m_CurrentDatabase

DatabaseProviderFactory *	m_CurrentProvider

DbDad *	m_Dad

int	m_PrevBatchItem

string	m_LastRequestor

bool	m_BatchChanged

bool	m_TransactionStarted

Additional Inherited Members
Static Public Member Functions inherited from Endpoint
static void *	StartInNewThread (void *)

static void	setManagementCallback (void(callback)(TransactionStatus::TransactionStatusEnum, void ))

static void	setGlobalSettings (AppSettings *settings)

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

DbPublisher::DbPublisher ( )

DbPublisher::~DbPublisher ( )

Member Function Documentation

void DbPublisher::Abort ( )

virtual

Aborts the work and rolls back the data

Implements Endpoint.

void DbPublisher::Commit ( )

virtual

Commits the work

Implements Endpoint.

string DbPublisher::getDad ( const string & dadFilename )

private

pthread_t DbPublisher::getWatcherThreadId ( )

inlinevirtual

Implements Endpoint.

void DbPublisher::Init ( )

virtual

Implements Endpoint.

void DbPublisher::internalStart ( )

protectedvirtual

Implements Endpoint.

void DbPublisher::internalStop ( )

protectedvirtual

Implements Endpoint.

bool DbPublisher::moreMessages ( ) const

inlinevirtual

Reimplemented from Endpoint.

string DbPublisher::Prepare ( )

virtual

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

Returns: True if it can process the data

Implements Endpoint.

void DbPublisher::Process ( const string & correlationId )

virtual

Processes the data

Returns: True if everything worked fine

Implements Endpoint.

void DbPublisher::Rollback ( )

virtual

Rollback

Implements Endpoint.

string DbPublisher::SaveBlobToFile ( const string & xmlData )

private

void DbPublisher::UploadMessage	(	const string &	theDadFileName,
		const string &	xmlData,
		const string &	xmlTable,
		const string &	hash
	)

private

Member Data Documentation

string DbPublisher::m_AckDadFileName

private

bool DbPublisher::m_BatchChanged

private

string DbPublisher::m_BlobFilePattern

private

string DbPublisher::m_BlobLocator

private

string DbPublisher::m_CfgDatabaseName

private

string DbPublisher::m_CfgUserName

private

string DbPublisher::m_CfgUserPassword

private

Database* DbPublisher::m_CurrentDatabase

private

string DbPublisher::m_CurrentGroupId

private

string DbPublisher::m_CurrentMessageId

private

unsigned long DbPublisher::m_CurrentMessageLength

private

DatabaseProviderFactory* DbPublisher::m_CurrentProvider

private

DbDad* DbPublisher::m_Dad

private

CacheManager< string, string > DbPublisher::m_DadCache

private

DbDad::DadOptions DbPublisher::m_DadOptions

private

string DbPublisher::m_DatabaseName

private

string DbPublisher::m_DatabaseProvider

private

ConnectorsDDInfo DbPublisher::m_DDSettings

private

bool DbPublisher::m_InsertBlob

private

string DbPublisher::m_LastRequestor

private

int DbPublisher::m_PrevBatchItem

private

string DbPublisher::m_RepliesTableName

private

string DbPublisher::m_SPinsertXmlData

private

string DbPublisher::m_TableName

private

bool DbPublisher::m_TransactionStarted

private

string DbPublisher::m_UserName

private

string DbPublisher::m_UserPassword

private

MqWatcher DbPublisher::m_Watcher

private

string DbPublisher::m_WatchQueue

private

string DbPublisher::m_WatchQueueManager

private

string DbPublisher::m_WatchTransportURI

private

bool DbPublisher::m_WMQBatchFilter

private

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

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation