Public Member Functions | Protected Attributes

CommunicationManagerImpl Class Reference

#include <H:/WOSH/win32_vc2010/src/bundles/CommunicationManager/CommunicationManagerImpl.h>

List of all members.

Public Member Functions

 CommunicationManagerImpl (BundleGeneric &bundle)
 Default constructor. Init vars.
virtual ~CommunicationManagerImpl ()
 Deconstructor. If thread is still running, it will be stopped.
Setters
void setListener (ICommunicationManagerListener *list)
void setFlowTimeOut (long seconds)
void setFlowRetryTime (long seconds)
void setFlowRetryCount (long times)
Getters
long getFlowTimeOut () const
long getFlowRetryTime () const
long getFlowRetryCount () const
tStrCommunicatorMapgetCommunicators ()
tStrInterpreterMapgetInterpreters ()
tLongNotificationFlowMap & getMessages ()
tLongNotificationFlowMap & getMessagesArchived ()

Protected Member Functions

Internal methods
bool processNotification_ (NotificationFlow *notification)
virtual void runThread ()

Protected Attributes

tStrCommunicatorMap comms
 communicators
tStrInterpreterMap transl
 interpreters
tLongNotificationFlowMap messages
 processing messages cache [flowid, notf*]
tLongNotificationFlowMap messagesArchived
 archived messages cache [flowid, notf*]
long messageArchiveSize
 size of archived messages cache
long flowTimeout
 timeout of notification-flow processing
long flowRetryTime
 minimum number of seconds between each flow-processing retry [0=disabled]
long flowRetryCount
 maximum number of retries of flow-processing [0=disabled]
MessageQueue msgQueue
 messages' queue
ICommunicationManagerListenerlistener
 callbacks

Detailed Description

Version:
Id:
CommunicationManagerImpl.h 3775 2011-01-01 16:38:17Z alex
Author:
Alessandro Polo

Definition at line 60 of file CommunicationManagerImpl.h.


Constructor & Destructor Documentation

CommunicationManagerImpl::CommunicationManagerImpl ( BundleGeneric bundle )

Default constructor. Init vars.

Parameters:
bundle[in] the parent bundle, see BundleGenericWorker interface

Definition at line 52 of file CommunicationManagerImpl.cpp.

References flowRetryCount, flowRetryTime, flowTimeout, listener, and messageArchiveSize.

CommunicationManagerImpl::~CommunicationManagerImpl (  ) [virtual]

Deconstructor. If thread is still running, it will be stopped.

Definition at line 64 of file CommunicationManagerImpl.cpp.

References comms, wosh::BundleGenericWorker::Log, wosh::LOG_VERBOSE, messages, messagesArchived, and transl.


Member Function Documentation

bool CommunicationManagerImpl::processNotification_ ( NotificationFlow notification ) [protected]

Todo:
reply to sender that it is (čartially) archived

Definition at line 124 of file CommunicationManagerImpl.cpp.

References flowRetryCount, flowRetryTime, flowTimeout, wosh::BundleGenericWorker::Log, wosh::LOG_CRITICAL, wosh::LOG_VERBOSE, and wosh::LOG_WARNING.

Referenced by runThread().

void CommunicationManagerImpl::runThread (  ) [protected, virtual]

Member Data Documentation

communicators

Definition at line 146 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().

maximum number of retries of flow-processing [0=disabled]

Definition at line 155 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

minimum number of seconds between each flow-processing retry [0=disabled]

Definition at line 154 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

timeout of notification-flow processing

Definition at line 153 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

callbacks

Definition at line 159 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl().

size of archived messages cache

Definition at line 151 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl().

tLongNotificationFlowMap CommunicationManagerImpl::messages [protected]

processing messages cache [flowid, notf*]

Definition at line 149 of file CommunicationManagerImpl.h.

Referenced by runThread(), and ~CommunicationManagerImpl().

tLongNotificationFlowMap CommunicationManagerImpl::messagesArchived [protected]

archived messages cache [flowid, notf*]

Definition at line 150 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().

messages' queue

Definition at line 157 of file CommunicationManagerImpl.h.

interpreters

Definition at line 147 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().


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

Generated on Tue Feb 8 2011 09:33:24 for WOSH system 0.8.888 [wolf] by Alessandro Polo, using DoxyGen 1.7.2 hosted by WOSH Framework