From df58679ddae8a97b1a64fe3ec62298b11b86a76d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?L=C3=A9o=20Lam?= Date: Tue, 2 Feb 2021 19:15:11 +0100 Subject: ksys: Add MessageBroker and finish MessageDispatcher --- src/KingSystem/Utils/Thread/MessageBroker.cpp | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 src/KingSystem/Utils/Thread/MessageBroker.cpp (limited to 'src/KingSystem/Utils/Thread/MessageBroker.cpp') diff --git a/src/KingSystem/Utils/Thread/MessageBroker.cpp b/src/KingSystem/Utils/Thread/MessageBroker.cpp new file mode 100644 index 00000000..903ec4d6 --- /dev/null +++ b/src/KingSystem/Utils/Thread/MessageBroker.cpp @@ -0,0 +1,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 -- cgit v1.2.3