fintp_transport
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
FinTP::AmqHelper Member List

This is the complete list of members for FinTP::AmqHelper, including all inherited members.

AMQ enum valueFinTP::TransportHelper
AmqHelper(const std::string &connectionstring="")FinTP::AmqHelperexplicit
AQ enum valueFinTP::TransportHelper
clearMessages()FinTP::AmqHelpervirtual
clearSSLOptions()FinTP::AmqHelpervirtual
closeQueue()FinTP::AmqHelperprivate
commit()FinTP::AmqHelpervirtual
connect(const string &queueManagerName="", const string &transportUri="", bool force=false)FinTP::AmqHelpervirtual
connect(const string &queueManagerName, const string &transportUri, const string &keyRepository, const string &sslCypherSpec, const string &sslPeerName, bool force=false)FinTP::AmqHelpervirtual
CreateHelper(const TransportHelper::TRANSPORT_HELPER_TYPE &helperType)FinTP::TransportHelperstatic
createMqLogPublisher(const NameValueCollection &propSettings, bool &isDefault)FinTP::TransportHelperstatic
createMsg()FinTP::AmqHelper
DEPRECATED(virtual void openQueue(const string &queueName))FinTP::TransportHelperinline
DEPRECATED(virtual void closeQueue())FinTP::TransportHelperinline
disconnect()FinTP::AmqHelpervirtual
doConnect(const string &brokerURIName, bool force)FinTP::AmqHelperprivate
doGetOne(ManagedBuffer *buffer, bool getForClean, bool syncpoint=true)FinTP::AmqHelper
FINTPGROUPIDFinTP::AmqHelperprivatestatic
FINTPGROUPSEQFinTP::AmqHelperprivatestatic
FINTPLASTINGROUPFinTP::AmqHelperprivatestatic
getApplicationName() const FinTP::AmqHelperinlinevirtual
getGroupMessage(ManagedBuffer *groupMessageBuffer, const string &groupId, bool &isCleaningUp)FinTP::AmqHelpervirtual
getLastCorrelId() const FinTP::TransportHelperinline
getLastFeedback() const FinTP::TransportHelperinline
getLastGroupId() const FinTP::TransportHelperinline
getLastGroupSequence() const FinTP::TransportHelperinline
getLastMessageFormat() const FinTP::AmqHelpervirtual
getLastMessageId() const FinTP::TransportHelperinline
getLastMessageLength() const FinTP::TransportHelperinline
getLastMessageType()FinTP::AmqHelperinlinevirtual
getLastReplyBrokerURI() const FinTP::AmqHelperinline
getLastReplyOptions() const FinTP::AmqHelpervirtual
getLastReplyQueue() const FinTP::TransportHelperinline
getLastReplyQueueManager() const FinTP::AmqHelperinlinevirtual
getLastSequenceId() const FinTP::AmqHelperinline
getMessagePutTime()FinTP::AmqHelper
getOne(bool getForClean=false)FinTP::AmqHelper
getOne(unsigned char *buffer, size_t maxSize, bool syncpoint=true)FinTP::AmqHelpervirtual
getOne(ManagedBuffer *buffer, bool syncpoint=true, bool keepJMSHeader=true)FinTP::AmqHelperinlinevirtual
FinTP::TransportHelper::getOne(ManagedBuffer *buffer)FinTP::TransportHelperinlinevirtual
getQueueDepth(const std::string &queueName="")FinTP::AmqHelper
FinTP::TransportHelper::getQueueDepth(const string &queueName)=0FinTP::TransportHelperpure virtual
FinTP::TransportHelper::getQueueDepth()FinTP::TransportHelperinline
getReplyUserData() const FinTP::TransportHelperinline
isLastInGroup() const FinTP::TransportHelperinline
m_ApplicationNameFinTP::TransportHelperprotected
m_AutoAbandonFinTP::TransportHelperprotected
m_AutoAcknowledgeConsumerFinTP::AmqHelperprivate
m_AutoAcknowledgeProducerFinTP::AmqHelperprivate
m_AutoAcknowledgeSessionFinTP::AmqHelperprivate
m_BackoutQueueNameFinTP::AmqHelperprivate
m_BackupQueueNameFinTP::TransportHelperprotected
m_BrokerURIOpenRefCountFinTP::AmqHelperprivate
m_ConnectionFinTP::AmqHelperprivate
m_ConnectionStringFinTP::AmqHelperprivate
m_ConsumerFinTP::AmqHelperprivate
m_CorrelationIdFinTP::TransportHelperprotected
m_FeedbackFinTP::TransportHelperprotected
m_GroupIdFinTP::TransportHelperprotected
m_GroupLogicOrderFinTP::AmqHelperprivate
m_GroupSequenceFinTP::TransportHelperprotected
m_LastInGroupFinTP::TransportHelperprotected
m_MessageCMSTimestampFinTP::AmqHelperprivate
m_MessageFormatPointerFinTP::AmqHelperprivate
m_MessageIdFinTP::TransportHelperprotected
m_MessageIdLengthFinTP::TransportHelperprotected
m_MessageLengthFinTP::TransportHelperprotected
m_MessagePutDateFinTP::TransportHelperprotected
m_MessagePutTimeFinTP::TransportHelperprotected
m_MessageTypeFinTP::AmqHelperprivate
m_ProducerFinTP::AmqHelperprivate
m_QueueBrowserFinTP::AmqHelperprivate
m_QueueNameFinTP::TransportHelperprotected
m_QueueOpenRefCountFinTP::TransportHelperprotected
m_ReplyBrokerURIFinTP::AmqHelperprivate
m_ReplyOptionsFinTP::AmqHelperprivate
m_ReplyQueueFinTP::TransportHelperprotected
m_ReplyUsrDataFinTP::TransportHelperprotected
m_SaveBackupFinTP::TransportHelperprotected
m_SelectorFinTP::AmqHelperprivate
m_SessionFinTP::AmqHelperprivate
m_SSLCypherSpecFinTP::TransportHelperprotected
m_SSLKeyRepositoryFinTP::TransportHelperprotected
m_SSLPeerNameFinTP::TransportHelperprotected
m_TimeoutFinTP::AmqHelperprivate
m_UsePassedAppNameFinTP::TransportHelperprotected
m_UsePassedCorrelIdFinTP::TransportHelperprotected
m_UsePassedGroupIdFinTP::TransportHelperprotected
m_UsePassedMessageIdFinTP::TransportHelperprotected
noMessage()FinTP::AmqHelperprivate
NONE enum valueFinTP::TransportHelper
openBackoutQueue(const std::string &queueName)FinTP::AmqHelper
openQueue(bool syncpoint, const std::string &queueName="")FinTP::AmqHelper
openQueue(const std::string &queueName="")FinTP::AmqHelper
parseTransportType(const string &transportType)FinTP::TransportHelperstatic
peek(const std::string &queueName="", bool first=true)FinTP::AmqHelper
FinTP::TransportHelper::peek(const string &queue="", bool first=true)=0FinTP::TransportHelperpure virtual
putGroupMessage(ManagedBuffer *buffer, const string &batchId, long messageSequence, bool isLast)FinTP::AmqHelpervirtual
putOne(const ManagedBuffer &buffer, bool syncpoint=true)FinTP::AmqHelper
putOne(unsigned char *buffer, size_t bufferSize, bool syncpoint=true)FinTP::AmqHelpervirtual
putOne(unsigned char *buffer, size_t bufferSize, cms::Message &msg)FinTP::AmqHelper
putOne(cms::Message &msg, bool syncpoint=true)FinTP::AmqHelper
putOneReply(unsigned char *buffer, size_t bufferSize, long feedback, TRANSPORT_MESSAGE_TYPE messageType=TMT_REPLY)FinTP::AmqHelpervirtual
putOneReply(const ManagedBuffer &buffer, long feedback)FinTP::AmqHelper
putOneRequest(unsigned char *buffer, size_t bufferSize, const std::string &rtqName, const std::string &rtbName, TransportReplyOptions &replyOptions)FinTP::AmqHelper
FinTP::TransportHelper::putOneRequest(unsigned char *buffer, size_t bufferSize, const string &rtqName, const string &rtqmName, TransportReplyOptions &replyOptions)=0FinTP::TransportHelperpure virtual
putSAAmessage(const TransportReplyOptions &replyOptions, const string &replyQueue, ManagedBuffer *buffer, const string &batchId, long messageSequence, bool isLast)FinTP::TransportHelpervirtual
putToDeadLetterQueue(cms::Message &msg, bool syncpoint=true)FinTP::AmqHelper
reconnect()FinTP::AmqHelper
resetUsePassedIds()FinTP::AmqHelperprivate
rollback()FinTP::AmqHelpervirtual
send(const string &queueName, cms::Message &msg, bool syncpoint=true)FinTP::AmqHelperprivate
setApplicationName(const std::string &applicationName)FinTP::AmqHelper
FinTP::TransportHelper::setApplicationName(const string &applicationName)=0FinTP::TransportHelperpure virtual
setAutoAbandon(const int retries)FinTP::TransportHelpervirtual
setBackupQueue(const std::string &queueName)FinTP::AmqHelper
FinTP::TransportHelper::setBackupQueue(const string &queueName)FinTP::TransportHelpervirtual
setConnectionBrokerURI()FinTP::AmqHelperinlineprivate
setCorrelationId(const std::string &correlId)FinTP::AmqHelper
FinTP::TransportHelper::setCorrelationId(const string &correlId)FinTP::TransportHelpervirtual
setGroupId(const std::string &groupId)FinTP::AmqHelper
FinTP::TransportHelper::setGroupId(const string &groupId)FinTP::TransportHelpervirtual
setLastMessageIds(const cms::Message &msg)FinTP::AmqHelperprivate
setLastMessageInfo(cms::Message *msg, ManagedBuffer *buffer, bool browse=false, bool get=true, bool syncpoint=true)FinTP::AmqHelperprivate
setLastMessageReplyData(const cms::Message &msg)FinTP::AmqHelperprivate
setMessageFormat(const string &format)FinTP::AmqHelpervirtual
setMessageId(const std::string &messageId)FinTP::AmqHelper
FinTP::TransportHelper::setMessageId(const string &messageId)FinTP::TransportHelpervirtual
setReplyUserData(const string &usrData)FinTP::TransportHelperinline
setSequenceId(int sequenceId)FinTP::AmqHelper
setTimeout(int millisecs)FinTP::AmqHelper
TMT_DATAGRAM enum valueFinTP::TransportHelper
TMT_NONEFinTP::TransportHelperstatic
TMT_REPLY enum valueFinTP::TransportHelper
TMT_REPORT enum valueFinTP::TransportHelper
TMT_REQUEST enum valueFinTP::TransportHelper
TMT_RF_HEADER_2FinTP::TransportHelperstatic
TMT_STRINGFinTP::TransportHelperstatic
ToString(TRANSPORT_MESSAGE_TYPE messageType)FinTP::AmqHelperprivate
ToTransportMessageType(const string &messageType)FinTP::AmqHelperprivate
TRANSPORT_HELPER_TYPE enum nameFinTP::TransportHelper
TRANSPORT_MESSAGE_TYPE enum nameFinTP::TransportHelper
TransportHelper(unsigned int messageIdLength)FinTP::TransportHelperprotected
updateSelector(string &selector)FinTP::AmqHelperprivate
WMQ enum valueFinTP::TransportHelper
writeToBuffer(ManagedBuffer &buffer, const unsigned char *rawBuffer)FinTP::AmqHelperprivate
~AmqHelper()FinTP::AmqHelper
~TransportHelper()FinTP::TransportHelperinlinevirtual