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 " |
20 | #include "message/Message.h" |
| 21 | #include " |
21 | #include "utils/Logger.h" |
| 22 | #include " |
22 | #include "utils/Thread.h" |
| 23 | #include " |
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 |
29 | using namespace utils; |
| 30 | using namespace |
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 | ||