src/KingSystem/Utils/Thread/MessageBroker.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

#include "KingSystem/Utils/Thread/MessageBroker.h"
#include "KingSystem/Utils/Thread/MessageTransceiverBase.h"

namespace ksys {

IMessageBroker::IMessageBroker() = default;

IMessageBroker::~IMessageBroker() = default;

bool IMessageBroker::registerTransceiver(const MessageTransceiverBase& transceiver) {
    return getRegister()->registerTransceiver(*transceiver.getId());
}

void IMessageBroker::deregisterTransceiver(const MessageTransceiverBase& transceiver) {
    return getRegister()->deregisterTransceiver(*transceiver.getId());
}

int IMessageBroker::countTransceivers() {
    return getRegister()->countTransceivers();
}

}  // namespace ksys