FinTP::MqWatcher Class Reference

#include <MqWatcher.h>

Inheritance diagram for FinTP::MqWatcher:

Public Types
enum	WatchOptions { NotifyGroups = 1, NotifyMessage = 2, NotifyUnique = 4 }
Public Types inherited from FinTP::AbstractWatcher
typedef WorkItemPool < NotificationObject >	NotificationPool

Public Member Functions
	MqWatcher (NotificationPool *notificationPool, const string &queue="", const string &queueManager="", const string &channelDefinition="", const string &connectionString="")
	~MqWatcher ()
void	setHelperType (const TransportHelper::TRANSPORT_HELPER_TYPE &helperType)
void	setQueue (const string &queue)
void	setQueueManager (const string &queue)
void	setTransportURI (const string &transportURI)
void	setWatchOptions (int options)
void	setSSLCypherSpec (const string &cypherSpec)
void	setSSLPeerName (const string &peerName)
void	setSSLKeyRepository (const string &keyRepository)
Public Member Functions inherited from FinTP::AbstractWatcher
void	setCallback (void(*callback)(const NotificationObject *))
void	setNotificationPool (NotificationPool *notificationPool)
void	setIdleCallback (void(*callback)(void), unsigned int seconds)
virtual	~AbstractWatcher ()
void	setEnableRaisingEvents (bool val)
void	setObjectPrepareMethod (void *(*prepareCallback)(void *))
void	setNotificationType (const NotificationObject::NotificationType notifType)
pthread_t	getThreadId ()
void	waitForExit ()
Public Member Functions inherited from FinTP::InstrumentedObject
void	registerCounter (const string &ownerTypeName, const string &counterName, const InstrumentedObject *iobject)

Protected Member Functions
void	internalScan ()
Protected Member Functions inherited from FinTP::AbstractWatcher
	AbstractWatcher (NotificationPool *notificationPool, void *(*prepareCallback)(void *object)=NULL)
	AbstractWatcher (void(*callback)(const NotificationObject *), void *(*prepareCallback)(void *object)=NULL)
Protected Member Functions inherited from FinTP::InstrumentedObject
	InstrumentedObject ()
virtual	~InstrumentedObject ()
string	InternalGetCounters () const

Private Attributes
int	m_WatchOptions
string	m_Queue
string	m_QueueManager
string	m_TransportURI
string	m_SSLKeyRepos
string	m_SSLCypherSpec
string	m_SSLPeerName
TransportHelper::TRANSPORT_HELPER_TYPE	m_HelperType

Additional Inherited Members
Static Public Member Functions inherited from FinTP::InstrumentedObject
static unsigned int	GetIntrumentedInstanceNo ()
static void	RemoveAllCounters ()
static string	Report ()
static string	Collect ()
Static Public Attributes inherited from FinTP::InstrumentedObject
static InstrumentedObject	Instance
static pthread_mutex_t	ObjMutex = PTHREAD_MUTEX_INITIALIZER
Protected Attributes inherited from FinTP::AbstractWatcher
void(*	m_Callback )(const NotificationObject *notification)
void *(*	m_PrepareCallback )(void *object)
void(*	m_IdleCallback )(void)
pthread_t	m_ScanThreadId
bool	m_Enabled
NotificationObject::NotificationType	m_NotificationType
unsigned int	m_IdleTimeout
NotificationPool *	m_NotificationPool
Protected Attributes inherited from FinTP::InstrumentedObject
map< string, unsigned long >	m_Counters
map< string, const InstrumentedObject * >	m_RegisteredObjects
unsigned int	m_RegisterCounter
vector< string >	m_CollectedReports

Member Enumeration Documentation

enum FinTP::MqWatcher::WatchOptions

Enumerator
NotifyGroups
NotifyMessage
NotifyUnique

Constructor & Destructor Documentation

MqWatcher::MqWatcher ( NotificationPool *  notificationPool, const string &  queue = "", const string &  queueManager = "", const string &  channelDefinition = "", const string &  connectionString = ""  )

explicit

MqWatcher::~MqWatcher

(

)

Member Function Documentation

void MqWatcher::internalScan ( )

protectedvirtual

Implements FinTP::AbstractWatcher.

void MqWatcher::setHelperType

(

const TransportHelper::TRANSPORT_HELPER_TYPE &

helperType

)

void MqWatcher::setQueue

(

const string &

queue

)

void MqWatcher::setQueueManager

(

const string &

queue

)

void FinTP::MqWatcher::setSSLCypherSpec ( const string &  cypherSpec )

inline

void FinTP::MqWatcher::setSSLKeyRepository ( const string &  keyRepository )

inline

void FinTP::MqWatcher::setSSLPeerName ( const string &  peerName )

inline

void MqWatcher::setTransportURI

(

const string &

transportURI

)

void FinTP::MqWatcher::setWatchOptions ( int  options )

inline

Member Data Documentation

TransportHelper::TRANSPORT_HELPER_TYPE FinTP::MqWatcher::m_HelperType

private

string FinTP::MqWatcher::m_Queue

private

string FinTP::MqWatcher::m_QueueManager

private

string FinTP::MqWatcher::m_SSLCypherSpec

private

string FinTP::MqWatcher::m_SSLKeyRepos

private

string FinTP::MqWatcher::m_SSLPeerName

private

string FinTP::MqWatcher::m_TransportURI

private

int FinTP::MqWatcher::m_WatchOptions

private

---

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

• MqWatcher.h
• MqWatcher.cpp