MqFetcher Class Reference

#include <MqFetcher.h>

Inheritance diagram for MqFetcher:

Public Member Functions
	MqFetcher ()
	~MqFetcher ()
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...
bool	moreMessages () const
pthread_t	getWatcherThreadId ()
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	GetIDImageReference (XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument *doc)
	Geting image reference for ID message More...

Private Attributes
MqWatcher	m_Watcher
string	m_WatchQueue
string	m_WatchQueueManager
string	m_TransportURI
string	m_StrictSwiftFormat
SwiftFormatFilter *	m_SAASingleFilter
SAAFilter *	m_SAAGroupFilter
string	m_SSLKeyRepos
string	m_SSLCypherSpec
string	m_SSLPeerName
bool	m_IsSigned
string	m_CertificateFileName
string	m_CertificatePasswd
string	m_CurrentMessageId
string	m_CurrentGroupId
unsigned long	m_CurrentMessageLength
int	m_CurrentSequence
string	m_BatchXsltFile
TransportHelper *	m_CurrentHelper
Database *	m_CurrentDatabase
DatabaseProviderFactory *	m_CurrentProvider
string	m_DatabaseProvider
string	m_DatabaseName
string	m_UserName
string	m_UserPassword
string	m_IDCertificateFileName
string	m_IDCertificatePasswd
string	m_LAUKey
bool	m_IsCurrentMessageID
bool	m_IsIDsEnabled
string	m_firstBatchId
string	m_PreviousImageRef

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

MqFetcher::MqFetcher

(

)

MqFetcher::~MqFetcher

(

)

Member Function Documentation

void MqFetcher::Abort ( )

virtual

Aborts the work and rolls back the data

Implements Endpoint.

void MqFetcher::Commit ( )

virtual

Commits the work

Summary> Aborts the current message/batch /Summary> Note> Rollback messages that were put and the commit messages that we got.

Messages that we got should be moved to dead letter queue instead of being committed. /Note>

Implements Endpoint.

string MqFetcher::GetIDImageReference ( XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument *  doc )

private

Geting image reference for ID message

Returns

Image reference

pthread_t MqFetcher::getWatcherThreadId ( )

inlinevirtual

Implements Endpoint.

void MqFetcher::Init ( )

virtual

Implements Endpoint.

void MqFetcher::internalStart ( )

protectedvirtual

Implements Endpoint.

void MqFetcher::internalStop ( )

protectedvirtual

Implements Endpoint.

bool MqFetcher::moreMessages ( ) const

virtual

Reimplemented from Endpoint.

string MqFetcher::Prepare ( )

virtual

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

Returns

True if it can process the data

Implements Endpoint.

void MqFetcher::Process ( const string &  correlationId )

virtual

Processes the data

Returns

True if everything worked fine

Implements Endpoint.

void MqFetcher::Rollback ( )

virtual

Rollback

Implements Endpoint.

Member Data Documentation

string MqFetcher::m_BatchXsltFile

private

string MqFetcher::m_CertificateFileName

private

string MqFetcher::m_CertificatePasswd

private

Database* MqFetcher::m_CurrentDatabase

private

string MqFetcher::m_CurrentGroupId

private

TransportHelper* MqFetcher::m_CurrentHelper

private

string MqFetcher::m_CurrentMessageId

private

unsigned long MqFetcher::m_CurrentMessageLength

private

DatabaseProviderFactory* MqFetcher::m_CurrentProvider

private

int MqFetcher::m_CurrentSequence

private

string MqFetcher::m_DatabaseName

private

string MqFetcher::m_DatabaseProvider

private

string MqFetcher::m_firstBatchId

private

string MqFetcher::m_IDCertificateFileName

private

string MqFetcher::m_IDCertificatePasswd

private

bool MqFetcher::m_IsCurrentMessageID

private

bool MqFetcher::m_IsIDsEnabled

private

bool MqFetcher::m_IsSigned

private

string MqFetcher::m_LAUKey

private

string MqFetcher::m_PreviousImageRef

private

SAAFilter* MqFetcher::m_SAAGroupFilter

private

SwiftFormatFilter* MqFetcher::m_SAASingleFilter

private

string MqFetcher::m_SSLCypherSpec

private

string MqFetcher::m_SSLKeyRepos

private

string MqFetcher::m_SSLPeerName

private

string MqFetcher::m_StrictSwiftFormat

private

string MqFetcher::m_TransportURI

private

string MqFetcher::m_UserName

private

string MqFetcher::m_UserPassword

private

MqWatcher MqFetcher::m_Watcher

private

string MqFetcher::m_WatchQueue

private

string MqFetcher::m_WatchQueueManager

private

---

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

• MqFetcher.h
• MqFetcher.cpp