1 #ifndef FACT_MessageDim 2 #define FACT_MessageDim 8 #include "../externals/Queue.h" 20 MessageDimTX(
const std::string &name, std::ostream &out=std::cout);
Queue< std::tuple< Time, std::string, int > > fMsgQueue
The base implementation of a distributed messaging system.
Adds some functionality to boost::posix_time::ptime for our needs.
bool UpdateService(const std::tuple< Time, std::string, int > &data)
int Write(const Time &t, const std::string &txt, int qos=kInfo)
MessageDimTX(const std::string &name, std::ostream &out=std::cout)
An info telling something which can be interesting to know.
void SetMinLogLevel(int min=0)
Based on MessageImp, redirects log-output to a Dim service MESSAGE.
DimStampedInfo fDimMessage
Based on MessageImp, subscribes to a MESSAGE service in the Dim network.
bool MessageQueueEmpty() const
void SetDebug(bool b=true)