Subversion Repositories HomeAutomation

Rev

Rev 1311 | Rev 1317 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 1311 Rev 1315
Line 16... Line 16...
16 
#include <boost/thread/mutex.hpp>
 16 
#include <boost/thread/mutex.hpp>
17 
#include <boost/thread/condition.hpp>
 17 
#include <boost/thread/condition.hpp>
18 
#include <boost/thread/locks.hpp>
 18 
#include <boost/thread/locks.hpp>
19 
#include "Broker.h"
 19 
#include "Broker.h"
20 
#include "message/Message.h"
 20 
#include "message/Message.h"
21 
#include "utils/Logger.h"
 21 
#include "log/Logger.h"
22 
#include "utils/Thread.h"
 22 
#include "utils/Thread.h"
23 
#include "utils/TSQueue.hpp"
 23 
#include "utils/TSQueue.hpp"
24 
#include <boost/make_shared.hpp>
 24 
#include <boost/make_shared.hpp>
25 
 
 25 
 
26 
namespace atom {
 26 
namespace atom {
Line 44... Line 44...
44 
 
 44 
 
45 
    void put(Message::pointer message);
 45 
    void put(Message::pointer message);
46 
    virtual void onNewMessage(Message::pointer message);
 46 
    virtual void onNewMessage(Message::pointer message);
47 
 
 47 
 
48 
private:
 48 
private:
49 
    Logger LOG;
 49 
    log::Logger LOG;
50 
    atom::utils::TSQueue<Message::pointer> myQueue;
 50 
    utils::TSQueue<Message::pointer> myQueue;
51 
    bool myReceiveFromMyself;
 51 
    bool myReceiveFromMyself;
52 
    boost::condition myCondition;
 52 
    boost::condition myCondition;
53 
    boost::mutex myMutex;
 53 
    boost::mutex myMutex;
54 
 
 54 
 
55 
    void newMessageHandler(Message::pointer message);
 55 
    void newMessageHandler(Message::pointer message);