#include <RoutingDbOp.h>

Public Types
enum	BatchItemsType { Batch_Items, DD_Ref_Reply, Sepa_Sts_Reply }

Public Member Functions
	~RoutingDbOp ()

Static Public Member Functions
static void	Terminate ()

static void	TerminateSelf ()

static void	SetConfigDataSection (const NameValueCollection &dataSection)

static void	SetConfigCfgSection (const NameValueCollection &cfgSection)

static bool	isConnected ()

static string	GetActiveRoutingSchemaName ()

static DataSet *	GetActiveRoutingSchemas ()

static DataSet *	ReadRoutingRules (const string &schemaName)

static DataSet *	ReadRoutingRule (const long ruleId)

static DataSet *	GetCOTMarkers ()

static unsigned long	Archive ()

static DataSet *	GetRoutingJob (const string &jobId)

static DataSet *	ReadJobParams (const string &jobId)

static void	CommitJob (const string &jobId, const bool isolate=true)

static void	AbortJob (const string &jobId)

static void	RollbackJob (const string &jobId)

static void	DeferJob (const string &jobId, const long deferedQueue, const string &routingPoint, const string &function, const int userId)

static void	ResumeJobs (const long deferedQueue)

static void	InsertJob (const string &jobId, const string &routingPoint, const string &function, const int userId)

static BatchManagerBase::BATCH_STATUS	BatchJob (const string &jobId, const string &sequence, const string &batchId, const string &correlId, const string &feedback, const string &xformItem, const string &amountBDP, const string &amountADP)

static BatchManagerBase::BATCH_STATUS	GetBatchStatus (const string &batchId, const string &batchUID, string &comBatchId, const int userId, const unsigned long batchCount, const string &batchAmount, const long serviceId, const string &routingPoint)

static void	UpdateBatchCode (const string &batchId, const string &code)

static void	TerminateBatch (const string &batchId, const string &batchType, const BatchManagerBase::BATCH_STATUS status, const string &reason)

static void	TerminateRapidBatch (const string &batchId, const int userId, const string &tableName, const string &responder)

static unsigned long	GetBatchCount (const string &batchId)

static DataSet *	GetBatchMessages (const string &batchId, const bool isReply, const string &issuer, int ddbtSettledReply=0)

static DataSet *	GetBatchMessages (const string &batchId, const string &tableName, const string &spName="GetMessagesInAssembly")

static DataSet *	GetBatchPart (const int userId, const string &receiver, const int serviceId, const string &queue)

static void	RemoveBatchMessages (const string &batchId, const string &tableName, const string &spName="DeleteMessagesInAssembly")

static void	UpdateOriginalBatchMessages (const string &batchid, const string &code=RoutingMessageEvaluator::FEEDBACKFTP_REFUSE)

static string	GetBatchType (const string &batchId, const string &tableName="BATCHJOBS", const string &sender="")

static void	InsertIncomingBatch (const string &batchId, const string &messageId, const string &messageNamespace)

static string	GetOriginalRef (const string &reference, const string &batchId)

static DataSet *	GetRoutingMessage (const string &tableName, const string &messageId)

static void	MoveRoutingMessage (const string &sourceTable, const string &destTable, const string &messageId, const string &payload, const string &batchId, const string &correlationId, const string &sessionId, const string &requestorService, const string &responderService, const string &requestType, const unsigned long priority, const short holdstatus, const long sequence, const string &feedback)

static void	DeleteRoutingMessage (const string &tableName, const string &messageId, bool isReply=false)

static void	InsertRoutingMessage (const string &tableName, const string &messageId, const string &payload, const string &batchId, const string &correlationId, const string &sessionId, const string &requestorService, const string &responderService, const string &requestType, const unsigned long priority, const short holdstatus, const long sequence, const string &feedback)

static void	UpdateRoutingMessage (const string &tableName, const string &messageId, const string &payload, const string &batchId, const string &correlationId, const string &sessionId, const string &requestorService, const string &responderService, const string &requestType, unsigned long priority, short holdstatus, long sequence, const string &feedback)

static string	GetOriginalPayload (const string &correlationId)

static string	GetOriginalMessageId (const string &correlationId)

static void	InsertBusinessMessage (const string &messageType, const string &senderApp, const string &receiverApp, const string &messageId, const string &correlationId, const vector< string > &keywords, const vector< string > &keywordValues)

static void	InsertBusinessMessage (const string &messageId, const string &correlationId, int crtQueue, const string &messageType, const string &senderBIC, const string &receiverBIC, const string &currDate, const string &currType, const string &currAmmount, const string &senderApp, const string &receiverApp, const string &trn, const string &relref, const string &mur, const string &iban, const string &ibanpl, const string &senderCorr, const string &receiverCorr, const int userid, const string &edToEdId, const string &orgInstrId, const string &orgTxId, const string &addMsgInf)

static void	UpdateBusinessMessageResponder (const string &messageId, const string &receiverApp)

static void	UpdateBusinessMessageUserId (const string &correlationId, const int userId)

static void	UpdateBusinessMessageValueDate (const string &correlationId, const string &newDate)

static void	UpdateBusinessMessageAck (const string &id, bool batch)

static void	UpdateLiquidities (const string &correlationId)

static void	UpdateBMAssembleResponder (const string &batchId, const string &receiverApp)

static bool	AggregationRequestOp (const string &aggregationTable, const RoutingAggregationCode &request, bool &trim)

static void	InsertAggregationRequest (const string &aggregationTable, const RoutingAggregationCode &request)

static bool	UpdateAggregationRequest (const string &aggregationTable, const RoutingAggregationCode &request, bool trim=false)

static bool	GetAggregationFields (const string &aggregationTable, RoutingAggregationCode &request, bool trim=false)

static string	GetReplyQueue (const string &senderApp)

static string	GetDuplicateQueue (const string &senderApp)

static string	GetDuplicateReplyQueue (const string &senderApp)

static string	GetDelayedReplyQueue (const string &senderApp)

static DataSet *	GetKeywordMappings ()

static DataSet *	GetKeywords ()

static map< string, bool >	GetDuplicateServices ()

static int	GetDuplicates (const string &service, const string &messageId)

static void	PurgeHashes (const int hours)

static unsigned int	GetNextSequence (const long serviceId)

static string	GetQueueName (const long queueId)

static long	GetQueueId (const string &queueName)

static RoutingQueue &	GetQueue (const long queueId)

static RoutingQueue &	GetQueue (const string &queueName)

static void	ChangeQueueHoldStatus (const string &queueName, const bool holdStatus)

static map< long, RoutingQueue > *	GetQueueCache ()

static map< string, string > *	GetReplyQueueCache ()

static map< string, string > *	GetDuplicateQueueCache ()

static map< string, string > *	GetDuplicateReplyQueueCache ()

static map< string, string > *	GetDelayedReplyQueueCache ()

static bool	CallBoolProcedure (const string &procName, const string &messageId, const string &messageTable)

static DataSet *	GetDelayedMessages (const string &tableName, const string &tokenId)

static void	UpdateDelayedId (const string &tableName, const string &messageId, const string &delayedId)

static DataSet *	GetEnrichData (const string &tableName, const string &filterId)

Private Member Functions
	RoutingDbOp ()

Static Private Member Functions
static void	Initialize ()

static void	CreateKeys ()

static void	DeleteData (void *data)

static void	DeleteConfig (void *data)

static Database *	getData ()

static Database *	getConfig ()

static DatabaseProviderFactory *	getProvider ()

static void	createProvider (const NameValueCollection &configSection)

static void	GetQueues ()

Static Private Attributes
static pthread_once_t	DatabaseKeysCreate = PTHREAD_ONCE_INIT

static pthread_key_t	DataKey

static pthread_key_t	ConfigKey

static DatabaseProviderFactory *	m_DatabaseProvider = NULL

static map< long, RoutingQueue > *	m_QueueIdCache = NULL

static map< string, string > *	m_ReplyQueueCache = NULL

static map< string, string > *	m_DuplicateQueueCache = NULL

static map< string, string > *	m_DuplicateReplyQueueCache = NULL

static map< string, string > *	m_DelayedReplyQueueCache = NULL

static pthread_mutex_t	m_SyncRoot = PTHREAD_MUTEX_INITIALIZER

static ConnectionString	m_ConfigConnectionString

static ConnectionString	m_DataConnectionString

Friends
class	RoutingEngine

class	RoutingSchema

Member Enumeration Documentation

enum RoutingDbOp::BatchItemsType

Enumerator
Batch_Items
DD_Ref_Reply
Sepa_Sts_Reply

Constructor & Destructor Documentation

RoutingDbOp::RoutingDbOp ( )

private

RoutingDbOp::~RoutingDbOp ( )

Member Function Documentation

void RoutingDbOp::AbortJob ( const string & jobId )

static

bool RoutingDbOp::AggregationRequestOp	(	const string &	aggregationTable,
		const RoutingAggregationCode &	request,
		bool &	trim
	)

static

unsigned long RoutingDbOp::Archive ( )

static

BatchManagerBase::BATCH_STATUS RoutingDbOp::BatchJob	(	const string &	jobId,
		const string &	sequence,
		const string &	batchId,
		const string &	correlId,
		const string &	feedback,
		const string &	xformItem,
		const string &	amountBDP,
		const string &	amountADP
	)

static

bool RoutingDbOp::CallBoolProcedure	(	const string &	procName,
		const string &	messageId,
		const string &	messageTable
	)

static

void RoutingDbOp::ChangeQueueHoldStatus	(	const string &	queueName,
		const bool	holdStatus
	)

static

void RoutingDbOp::CommitJob	(	const string &	jobId,
		const bool	isolate = `true`
	)

static

void RoutingDbOp::CreateKeys ( )

staticprivate

void RoutingDbOp::createProvider ( const NameValueCollection & configSection )

staticprivate

void RoutingDbOp::DeferJob	(	const string &	jobId,
		const long	deferedQueue,
		const string &	routingPoint,
		const string &	function,
		const int	userId
	)

static

void RoutingDbOp::DeleteConfig ( void * data )

staticprivate

void RoutingDbOp::DeleteData ( void * data )

staticprivate

void RoutingDbOp::DeleteRoutingMessage	(	const string &	tableName,
		const string &	messageId,
		bool	isReply = `false`
	)

static

string RoutingDbOp::GetActiveRoutingSchemaName ( )

static

DataSet * RoutingDbOp::GetActiveRoutingSchemas ( )

static

bool RoutingDbOp::GetAggregationFields	(	const string &	aggregationTable,
		RoutingAggregationCode &	request,
		bool	trim = `false`
	)

static

static unsigned long RoutingDbOp::GetBatchCount ( const string & batchId )

inlinestatic

DataSet * RoutingDbOp::GetBatchMessages	(	const string &	batchId,
		const bool	isReply,
		const string &	issuer,
		int	ddbtSettledReply = `0`
	)

static

DataSet * RoutingDbOp::GetBatchMessages	(	const string &	batchId,
		const string &	tableName,
		const string &	spName = `"GetMessagesInAssembly"`
	)

static

DataSet * RoutingDbOp::GetBatchPart	(	const int	userId,
		const string &	receiver,
		const int	serviceId,
		const string &	queue
	)

static

BatchManagerBase::BATCH_STATUS RoutingDbOp::GetBatchStatus	(	const string &	batchId,
		const string &	batchUID,
		string &	comBatchId,
		const int	userId,
		const unsigned long	batchCount,
		const string &	batchAmount,
		const long	serviceId,
		const string &	routingPoint
	)

static

string RoutingDbOp::GetBatchType	(	const string &	batchId,
		const string &	tableName = `"BATCHJOBS"`,
		const string &	sender = `""`
	)

static

Database * RoutingDbOp::getConfig ( )

staticprivate

DataSet * RoutingDbOp::GetCOTMarkers ( )

static

Database * RoutingDbOp::getData ( )

staticprivate

DataSet * RoutingDbOp::GetDelayedMessages	(	const string &	tableName,
		const string &	tokenId
	)

static

string RoutingDbOp::GetDelayedReplyQueue ( const string & senderApp )

static

static map< string, string >* RoutingDbOp::GetDelayedReplyQueueCache ( )

inlinestatic

string RoutingDbOp::GetDuplicateQueue ( const string & senderApp )

static

static map< string, string >* RoutingDbOp::GetDuplicateQueueCache ( )

inlinestatic

string RoutingDbOp::GetDuplicateReplyQueue ( const string & senderApp )

static

static map< string, string >* RoutingDbOp::GetDuplicateReplyQueueCache ( )

inlinestatic

int RoutingDbOp::GetDuplicates	(	const string &	service,
		const string &	messageId
	)

static

map< string, bool > RoutingDbOp::GetDuplicateServices ( )

static

DataSet * RoutingDbOp::GetEnrichData	(	const string &	tableName,
		const string &	filterId
	)

static

DataSet * RoutingDbOp::GetKeywordMappings ( )

static

DataSet * RoutingDbOp::GetKeywords ( )

static

unsigned int RoutingDbOp::GetNextSequence ( const long serviceId )

static

string RoutingDbOp::GetOriginalMessageId ( const string & correlationId )

static

string RoutingDbOp::GetOriginalPayload ( const string & correlationId )

static

string RoutingDbOp::GetOriginalRef	(	const string &	reference,
		const string &	batchId
	)

static

static DatabaseProviderFactory* RoutingDbOp::getProvider ( )

inlinestaticprivate

RoutingQueue & RoutingDbOp::GetQueue ( const long queueId )

static

RoutingQueue & RoutingDbOp::GetQueue ( const string & queueName )

static

static map< long, RoutingQueue >* RoutingDbOp::GetQueueCache ( )

inlinestatic

long RoutingDbOp::GetQueueId ( const string & queueName )

static

string RoutingDbOp::GetQueueName ( const long queueId )

static

void RoutingDbOp::GetQueues ( )

staticprivate

string RoutingDbOp::GetReplyQueue ( const string & senderApp )

static

static map< string, string >* RoutingDbOp::GetReplyQueueCache ( )

inlinestatic

DataSet * RoutingDbOp::GetRoutingJob ( const string & jobId )

static

DataSet * RoutingDbOp::GetRoutingMessage	(	const string &	tableName,
		const string &	messageId
	)

static

void RoutingDbOp::Initialize ( )

staticprivate

void RoutingDbOp::InsertAggregationRequest	(	const string &	aggregationTable,
		const RoutingAggregationCode &	request
	)

static

void RoutingDbOp::InsertBusinessMessage	(	const string &	messageType,
		const string &	senderApp,
		const string &	receiverApp,
		const string &	messageId,
		const string &	correlationId,
		const vector< string > &	keywords,
		const vector< string > &	keywordValues
	)

static

void RoutingDbOp::InsertBusinessMessage	(	const string &	messageId,
		const string &	correlationId,
		int	crtQueue,
		const string &	messageType,
		const string &	senderBIC,
		const string &	receiverBIC,
		const string &	currDate,
		const string &	currType,
		const string &	currAmmount,
		const string &	senderApp,
		const string &	receiverApp,
		const string &	trn,
		const string &	relref,
		const string &	mur,
		const string &	iban,
		const string &	ibanpl,
		const string &	senderCorr,
		const string &	receiverCorr,
		const int	userid,
		const string &	edToEdId,
		const string &	orgInstrId,
		const string &	orgTxId,
		const string &	addMsgInf
	)

static

void RoutingDbOp::InsertIncomingBatch	(	const string &	batchId,
		const string &	messageId,
		const string &	messageNamespace
	)

static

void RoutingDbOp::InsertJob	(	const string &	jobId,
		const string &	routingPoint,
		const string &	function,
		const int	userId
	)

static

void RoutingDbOp::InsertRoutingMessage	(	const string &	tableName,
		const string &	messageId,
		const string &	payload,
		const string &	batchId,
		const string &	correlationId,
		const string &	sessionId,
		const string &	requestorService,
		const string &	responderService,
		const string &	requestType,
		const unsigned long	priority,
		const short	holdstatus,
		const long	sequence,
		const string &	feedback
	)

static

bool RoutingDbOp::isConnected ( )

static

void RoutingDbOp::MoveRoutingMessage	(	const string &	sourceTable,
		const string &	destTable,
		const string &	messageId,
		const string &	payload,
		const string &	batchId,
		const string &	correlationId,
		const string &	sessionId,
		const string &	requestorService,
		const string &	responderService,
		const string &	requestType,
		const unsigned long	priority,
		const short	holdstatus,
		const long	sequence,
		const string &	feedback
	)

static

void RoutingDbOp::PurgeHashes ( const int hours )

static

DataSet * RoutingDbOp::ReadJobParams ( const string & jobId )

static

DataSet * RoutingDbOp::ReadRoutingRule ( const long ruleId )

static

DataSet * RoutingDbOp::ReadRoutingRules ( const string & schemaName )

static

void RoutingDbOp::RemoveBatchMessages	(	const string &	batchId,
		const string &	tableName,
		const string &	spName = `"DeleteMessagesInAssembly"`
	)

static

void RoutingDbOp::ResumeJobs ( const long deferedQueue )

static

void RoutingDbOp::RollbackJob ( const string & jobId )

static

void RoutingDbOp::SetConfigCfgSection ( const NameValueCollection & cfgSection )

static

void RoutingDbOp::SetConfigDataSection ( const NameValueCollection & dataSection )

static

void RoutingDbOp::Terminate ( )

static

void RoutingDbOp::TerminateBatch	(	const string &	batchId,
		const string &	batchType,
		const BatchManagerBase::BATCH_STATUS	status,
		const string &	reason
	)

static

void RoutingDbOp::TerminateRapidBatch	(	const string &	batchId,
		const int	userId,
		const string &	tableName,
		const string &	responder
	)

static

void RoutingDbOp::TerminateSelf ( )

static

bool RoutingDbOp::UpdateAggregationRequest	(	const string &	aggregationTable,
		const RoutingAggregationCode &	request,
		bool	trim = `false`
	)

static

void RoutingDbOp::UpdateBatchCode	(	const string &	batchId,
		const string &	code
	)

static

void RoutingDbOp::UpdateBMAssembleResponder	(	const string &	batchId,
		const string &	receiverApp
	)

static

void RoutingDbOp::UpdateBusinessMessageAck	(	const string &	id,
		bool	batch
	)

static

void RoutingDbOp::UpdateBusinessMessageResponder	(	const string &	messageId,
		const string &	receiverApp
	)

static

void RoutingDbOp::UpdateBusinessMessageUserId	(	const string &	correlationId,
		const int	userId
	)

static

void RoutingDbOp::UpdateBusinessMessageValueDate	(	const string &	correlationId,
		const string &	newDate
	)

static

void RoutingDbOp::UpdateDelayedId	(	const string &	tableName,
		const string &	messageId,
		const string &	delayedId
	)

static

void RoutingDbOp::UpdateLiquidities ( const string & correlationId )

static

void RoutingDbOp::UpdateOriginalBatchMessages	(	const string &	batchid,
		const string &	code = `RoutingMessageEvaluator::FEEDBACKFTP_REFUSE`
	)

static

void RoutingDbOp::UpdateRoutingMessage	(	const string &	tableName,
		const string &	messageId,
		const string &	payload,
		const string &	batchId,
		const string &	correlationId,
		const string &	sessionId,
		const string &	requestorService,
		const string &	responderService,
		const string &	requestType,
		unsigned long	priority,
		short	holdstatus,
		long	sequence,
		const string &	feedback
	)

static

Friends And Related Function Documentation

friend class RoutingEngine

friend

friend class RoutingSchema

friend

Member Data Documentation

pthread_key_t RoutingDbOp::ConfigKey

staticprivate

pthread_once_t RoutingDbOp::DatabaseKeysCreate = PTHREAD_ONCE_INIT

staticprivate

pthread_key_t RoutingDbOp::DataKey

staticprivate

ConnectionString RoutingDbOp::m_ConfigConnectionString

staticprivate

DatabaseProviderFactory * RoutingDbOp::m_DatabaseProvider = NULL

staticprivate

ConnectionString RoutingDbOp::m_DataConnectionString

staticprivate

map< string, string > * RoutingDbOp::m_DelayedReplyQueueCache = NULL

staticprivate

map< string, string > * RoutingDbOp::m_DuplicateQueueCache = NULL

staticprivate

map< string, string > * RoutingDbOp::m_DuplicateReplyQueueCache = NULL

staticprivate

map< long, RoutingQueue > * RoutingDbOp::m_QueueIdCache = NULL

staticprivate

map< string, string > * RoutingDbOp::m_ReplyQueueCache = NULL

staticprivate

pthread_mutex_t RoutingDbOp::m_SyncRoot = PTHREAD_MUTEX_INITIALIZER

staticprivate

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

Public Types

Public Member Functions

Static Public Member Functions

Private Member Functions

Static Private Member Functions

Static Private Attributes

Friends

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation