Subversion Repositories HomeAutomation

Rev

Rev 1310 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | SVN | RSS feed

  1. /*
  2.  * Broker.cpp
  3.  *
  4.  *  Created on: Jul 20, 2009
  5.  *      Author: Mattias Runge
  6.  */
  7.  
  8. #include "Broker.h"
  9.  
  10. namespace atom {
  11. namespace broker {
  12.  
  13. Broker::pointer Broker::Instance(new Broker());
  14.  
  15. void Broker::connect(const OnMessageSignal::slot_type & slot)
  16. {
  17.     LOG.info("New subscriber connected.");
  18.     this->onNewMessage.connect(slot);
  19. }
  20.  
  21. void Broker::put(Message::pointer message)
  22. {
  23.     LOG.info("New message received.");
  24.     this->onNewMessage(message);
  25. }
  26.  
  27. Broker::pointer Broker::getInstance()
  28. {
  29.     return Instance;
  30. }
  31.  
  32. Broker::Broker()
  33. {
  34.     LOG.setName("Broker");
  35. }
  36.  
  37. Broker::~Broker()
  38. {
  39. }
  40.  
  41. }
  42. }
  43.