Subversion Repositories HomeAutomation

Rev

Rev 1310 | 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.  
  12. Broker::Pointer Broker::instance_(new Broker());
  13.  
  14. Broker::Broker()
  15. {
  16.     LOG.setName("Broker");
  17. }
  18.  
  19. Broker::~Broker()
  20. {
  21. }
  22.  
  23. void Broker::Connect(const Signal_OnMessage::slot_type &slot)
  24. {
  25.     LOG.info("New subscriber connected.");
  26.     this->OnMessage.connect(slot);
  27. }
  28.  
  29. void Broker::Put(Message::Pointer message)
  30. {
  31.     LOG.info("New message received.");
  32.     this->OnMessage(message);
  33. }
  34.  
  35. Broker::Pointer Broker::GetInstance()
  36. {
  37.     return Broker::instance_;
  38. }
  39.  
  40. } // namespace atom
  41.