#include <MqPublisher.h>
|
void | GetIDImage (const string &groupId, const string &correlationId, string &imgRef, ManagedBuffer *outputSignedBuffer) |
|
MqPublisher::MqPublisher |
( |
| ) |
|
MqPublisher::~MqPublisher |
( |
| ) |
|
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 |
void MqPublisher::GetIDImage |
( |
const string & |
groupId, |
|
|
const string & |
correlationId, |
|
|
string & |
imgRef, |
|
|
ManagedBuffer * |
outputSignedBuffer |
|
) |
| |
|
private |
pthread_t MqPublisher::getWatcherThreadId |
( |
| ) |
|
|
inlinevirtual |
void MqPublisher::Init |
( |
| ) |
|
|
virtual |
void MqPublisher::internalStart |
( |
| ) |
|
|
protectedvirtual |
void MqPublisher::internalStop |
( |
| ) |
|
|
protectedvirtual |
bool MqPublisher::moreMessages |
( |
| ) |
const |
|
inlinevirtual |
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 |
string MqPublisher::XPathCallback |
( |
const string & |
itemNamespace | ) |
|
|
static |
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 |
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: