Subversion Repositories HomeAutomation

Rev

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

Rev 1309 Rev 1311
Line 15... Line 15...
15
#include <boost/thread.hpp>
15
#include <boost/thread.hpp>
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 "utils/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 {
27
namespace broker {
27
namespace broker {
28
 
28
 
29
using namespace atom::utils;
29
using namespace utils;
30
using namespace atom::message;
30
using namespace message;
31
 
31
 
32
class Subscriber : public boost::signals::trackable, public atom::utils::Thread
32
class Subscriber : public boost::signals::trackable, public atom::utils::Thread
33
{
33
{
34
    typedef boost::mutex::scoped_lock lock;
34
    typedef boost::mutex::scoped_lock lock;
35
 
35