Subversion Repositories HomeAutomation

Rev

Rev 1310 | Details | Compare with Previous | Last modification | View Log | SVN | RSS feed

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