#include <MqPublisher.h>

Inheritance diagram for MqPublisher:

Public Member Functions
	MqPublisher ()

	~MqPublisher ()

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

Static Public Member Functions
static string	XPathCallback (const string &itemNamespace)

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 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
void	GetIDImage (const string &groupId, const string &correlationId, string &imgRef, ManagedBuffer *outputSignedBuffer)

Private Attributes
MqWatcher	m_Watcher

string	m_WatchQueue

string	m_WatchQueueManager

string	m_WatchTransportURI

bool	m_WMQBatchFilter

string	m_AppQueue

string	m_AppQmgr

string	m_AppTransportURI

string	m_SSLKeyRepos

string	m_SSLCypherSpec

string	m_SSLPeerName

string	m_CertificateFileName

string	m_CertificatePasswd

string	m_RepliesQueue

bool	m_NotificationTypeXML

TransportHelper *	m_CurrentHelper

AbstractFilter *	m_SAAFilter

string	m_ParamFileXslt

string	m_StrictSwiftFormat

string	m_TransformFile

FinTPMessage::Metadata	m_Metadata

BatchManager < BatchZipArchiveStorage >	m_BatchManagerID

string	m_LastIdImageInZip

bool	m_IsIDsEnabled

bool	m_IsCurrentBatchID

int	m_CurrentSequence

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

Static Private Attributes
static MqPublisher *	m_Me = NULL

static const string	CHQ_NAMESPACE = "urn:swift:xs:CoreBlkChq"

static const string	PRN_NAMESPACE = "urn:swift:xs:CoreBlkPrmsNt"

static const string	BLX_NAMESPACE = "urn:swift:xs:CoreBlkBillXch"

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

Constructor & Destructor Documentation

MqPublisher::MqPublisher ( )

MqPublisher::~MqPublisher ( )

Member Function Documentation

void MqPublisher::Abort ( )

virtual

Aborts the work and rolls back the data

On abort mq filter is aborted too. This action consist in moving all group messages in DEAD.LETTER and commit current MQ transaction /summary>

Implements Endpoint.

void MqPublisher::Commit ( )

virtual

Commits the work

Implements Endpoint.

void MqPublisher::GetIDImage	(	const string &	groupId,
		const string &	correlationId,
		string &	imgRef,
		ManagedBuffer *	outputSignedBuffer
	)

private

pthread_t MqPublisher::getWatcherThreadId ( )

inlinevirtual

Implements Endpoint.

void MqPublisher::Init ( )

virtual

Implements Endpoint.

void MqPublisher::internalStart ( )

protectedvirtual

Implements Endpoint.

void MqPublisher::internalStop ( )

protectedvirtual

Implements Endpoint.

bool MqPublisher::moreMessages ( ) const

inlinevirtual

Reimplemented from Endpoint.

string MqPublisher::Prepare ( )

virtual

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

Returns: True if it can process the data

Implements Endpoint.

void MqPublisher::Process ( const string & correlationId )

virtual

Processes the data

Returns: True if everything worked fine

Implements Endpoint.

void MqPublisher::Rollback ( )

virtual

Rollback

Implements Endpoint.

string MqPublisher::XPathCallback ( const string & itemNamespace )

static

Member Data Documentation

const string MqPublisher::BLX_NAMESPACE = "urn:swift:xs:CoreBlkBillXch"

staticprivate

const string MqPublisher::CHQ_NAMESPACE = "urn:swift:xs:CoreBlkChq"

staticprivate

string MqPublisher::m_AppQmgr

private

string MqPublisher::m_AppQueue

private

string MqPublisher::m_AppTransportURI

private

BatchManager< BatchZipArchiveStorage > MqPublisher::m_BatchManagerID

private

string MqPublisher::m_CertificateFileName

private

string MqPublisher::m_CertificatePasswd

private

Database* MqPublisher::m_CurrentDatabase

private

TransportHelper* MqPublisher::m_CurrentHelper

private

DatabaseProviderFactory* MqPublisher::m_CurrentProvider

private

int MqPublisher::m_CurrentSequence

private

string MqPublisher::m_DatabaseName

private

string MqPublisher::m_DatabaseProvider

private

string MqPublisher::m_IDCertificateFileName

private

string MqPublisher::m_IDCertificatePasswd

private

bool MqPublisher::m_IsCurrentBatchID

private

bool MqPublisher::m_IsIDsEnabled

private

string MqPublisher::m_LastIdImageInZip

private

string MqPublisher::m_LAUKey

private

MqPublisher * MqPublisher::m_Me = NULL

staticprivate

FinTPMessage::Metadata MqPublisher::m_Metadata

private

bool MqPublisher::m_NotificationTypeXML

private

string MqPublisher::m_ParamFileXslt

private

string MqPublisher::m_RepliesQueue

private

AbstractFilter* MqPublisher::m_SAAFilter

private

string MqPublisher::m_SSLCypherSpec

private

string MqPublisher::m_SSLKeyRepos

private

string MqPublisher::m_SSLPeerName

private

string MqPublisher::m_StrictSwiftFormat

private

string MqPublisher::m_TransformFile

private

string MqPublisher::m_UserName

private

string MqPublisher::m_UserPassword

private

MqWatcher MqPublisher::m_Watcher

private

string MqPublisher::m_WatchQueue

private

string MqPublisher::m_WatchQueueManager

private

string MqPublisher::m_WatchTransportURI

private

bool MqPublisher::m_WMQBatchFilter

private

const string MqPublisher::PRN_NAMESPACE = "urn:swift:xs:CoreBlkPrmsNt"

staticprivate

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

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation