#include <FilePublisher.h>

Inheritance diagram for FilePublisher:

Public Member Functions
	FilePublisher ()

	~FilePublisher ()

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...

string	Serialize (XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument *doc, const string &xsltFilename, const string &filename, const unsigned long fileSize=0, const string &HMAC="")

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	WriteMessage (const char *message, const streamsize length)

string	HMAC_ShaGen (const string &inData, const string &privateKey)

string	SaveBlobToFile (const string &xmlData)

Private Attributes
MqWatcher	m_Watcher

string	m_WatchQueue

string	m_WatchQueueManager

string	m_WatchTransportURI

bool	m_WMQBatchFilter

bool	m_StrictSwiftFormat

bool	m_First

string	m_MessageId

string	m_BatchId

string	m_DestFileName

string	m_ReplyDestFileName

string	m_RenameFilePattern

ofstream	m_DestFile

FinTPMessage::Metadata	m_Metadata

string	m_BlobLocator

string	m_BlobFilePattern

Static Private Attributes
static string	m_DestinationPath = ""

static string	m_ReplyDestinationPath = ""

static string	m_ReplyPattern = ""

static string	m_Pattern = ""

static string	m_TransformFile = ""

static string	m_ReplyFeedback =""

static string	m_TempDestinationPath = ""

static FilePublisher *	m_Me = NULL

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

FilePublisher::FilePublisher ( )

FilePublisher::~FilePublisher ( )

Member Function Documentation

void FilePublisher::Abort ( )

virtual

Aborts the work and rolls back the data

Implements Endpoint.

void FilePublisher::Commit ( )

virtual

Commits the work

Implements Endpoint.

pthread_t FilePublisher::getWatcherThreadId ( )

inlinevirtual

Implements Endpoint.

string FilePublisher::HMAC_ShaGen	(	const string &	inData,
		const string &	privateKey
	)

private

void FilePublisher::Init ( )

virtual

Implements Endpoint.

void FilePublisher::internalStart ( )

protectedvirtual

Implements Endpoint.

void FilePublisher::internalStop ( )

protectedvirtual

Implements Endpoint.

bool FilePublisher::moreMessages ( ) const

virtual

Reimplemented from Endpoint.

string FilePublisher::Prepare ( )

virtual

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

Returns: True if it can process the data

Implements Endpoint.

void FilePublisher::Process ( const string & correlationId )

virtual

Processes the data

Returns: True if everything worked fine

Implements Endpoint.

void FilePublisher::Rollback ( )

virtual

Rollback

Implements Endpoint.

string FilePublisher::SaveBlobToFile ( const string & xmlData )

private

string FilePublisher::Serialize	(	XERCES_CPP_NAMESPACE_QUALIFIER DOMDocument *	doc,
		const string &	xsltFilename,
		const string &	filename,
		const unsigned long	fileSize = `0`,
		const string &	HMAC = `""`
	)

void FilePublisher::WriteMessage	(	const char *	message,
		const streamsize	length
	)

private

string FilePublisher::XPathCallback ( const string & itemNamespace )

static

Member Data Documentation

string FilePublisher::m_BatchId

private

string FilePublisher::m_BlobFilePattern

private

string FilePublisher::m_BlobLocator

private

ofstream FilePublisher::m_DestFile

private

string FilePublisher::m_DestFileName

private

string FilePublisher::m_DestinationPath = ""

staticprivate

bool FilePublisher::m_First

private

FilePublisher * FilePublisher::m_Me = NULL

staticprivate

string FilePublisher::m_MessageId

private

FinTPMessage::Metadata FilePublisher::m_Metadata

private

string FilePublisher::m_Pattern = ""

staticprivate

string FilePublisher::m_RenameFilePattern

private

string FilePublisher::m_ReplyDestFileName

private

string FilePublisher::m_ReplyDestinationPath = ""

staticprivate

string FilePublisher::m_ReplyFeedback =""

staticprivate

string FilePublisher::m_ReplyPattern = ""

staticprivate

bool FilePublisher::m_StrictSwiftFormat

private

string FilePublisher::m_TempDestinationPath = ""

staticprivate

string FilePublisher::m_TransformFile = ""

staticprivate

MqWatcher FilePublisher::m_Watcher

private

string FilePublisher::m_WatchQueue

private

string FilePublisher::m_WatchQueueManager

private

string FilePublisher::m_WatchTransportURI

private

bool FilePublisher::m_WMQBatchFilter

private

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