fintp_connectors
 All Classes Namespaces Files Functions Variables Enumerations Enumerator Macros Pages
MqPublisher Class Reference

#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 MqPublisherm_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: