From 28d84f4370a81cf5b398460f394f306d66bc9720 Mon Sep 17 00:00:00 2001 From: Kai Huebl Date: Fri, 18 Mar 2022 16:00:36 +0100 Subject: [PATCH] rename class --- .../MessageTransport/MsgTransPublisher.cpp | 95 --------------- .../MessageTransport/MsgTransPublisher.h | 57 --------- .../MessageTransport/MsgTransSubscriber.cpp | 112 ------------------ .../MessageTransport/MsgTransSubscriber.h | 66 ----------- 4 files changed, 330 deletions(-) delete mode 100644 src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp delete mode 100644 src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.h delete mode 100644 src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp delete mode 100644 src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.h diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp b/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp deleted file mode 100644 index 89a89950d..000000000 --- a/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp +++ /dev/null @@ -1,95 +0,0 @@ -/* - Copyright 2022 Kai Huebl (kai@huebl-sgh.de) - - Lizenziert gemäß Apache Licence Version 2.0 (die „Lizenz“); Nutzung dieser - Datei nur in Übereinstimmung mit der Lizenz erlaubt. - Eine Kopie der Lizenz erhalten Sie auf http://www.apache.org/licenses/LICENSE-2.0. - - Sofern nicht gemäß geltendem Recht vorgeschrieben oder schriftlich vereinbart, - erfolgt die Bereitstellung der im Rahmen der Lizenz verbreiteten Software OHNE - GEWÄHR ODER VORBEHALTE – ganz gleich, ob ausdrücklich oder stillschweigend. - - Informationen über die jeweiligen Bedingungen für Genehmigungen und Einschränkungen - im Rahmen der Lizenz finden Sie in der Lizenz. - - Autor: Kai Huebl (kai@huebl-sgh.de) - */ - -#include "OpcUaStackCore/Base/Log.h" -#include "OpcUaStackPubSub/Events/NetworkSendEvent.h" -#include "OpcUaStackPubSub/MessageTransport/MsgTransPublisher.h" - -using namespace OpcUaStackCore; - -namespace OpcUaStackPubSub -{ - - MsgTransPublisher::MsgTransPublisher( - const std::string& connectionName, - const std::string& serviceName, - OpcUaStackCore::IOThread::SPtr& ioThread, - OpcUaStackCore::MessageBus::SPtr& messageBus - ) - : ServerServiceBase() - { - // set parameter - ioThread_ = ioThread; - - // set parameter in server service base - serviceName_ = serviceName; - ServerServiceBase::ioThread_ = ioThread.get(); - strand_ = ioThread->createStrand(); - messageBus_ = messageBus; - - // register message bus receiver - MessageBusMemberConfig messageBusMemberConfig; - messageBusMemberConfig.strand(strand_); - messageBusMember_ = messageBus_->registerMember(serviceName_, messageBusMemberConfig); - - // activate receiver - activateReceiver( - [this](const MessageBusMember::WPtr& handleFrom, Message::SPtr& message) { - // receive message from internal message bus - - auto event = boost::static_pointer_cast(message); - switch (event->eventType()) - { - case EventType::NetworkSendEvent: - { - NetworkSendEvent::SPtr event = boost::static_pointer_cast(message); - // FIXME: todo - break; - } - default: - { - Log(Error, "invalid message received in message transport module") - .parameter("ServiceName", serviceName_) - .parameter("Event", (uint32_t)event->eventType()); - } - } - } - ); - } - - MsgTransPublisher::~MsgTransPublisher(void) - { - // deactivate receiver - deactivateReceiver(); - messageBus_->deregisterMember(messageBusMember_); - } - - bool - MsgTransPublisher::startup(void) - { - // FIXME: todo - return true; - } - - bool - MsgTransPublisher::shutdown(void) - { - // FIXME: todo - return true; - } - -} diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.h b/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.h deleted file mode 100644 index 087cd16c7..000000000 --- a/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.h +++ /dev/null @@ -1,57 +0,0 @@ -/* - Copyright 2022 Kai Huebl (kai@huebl-sgh.de) - - Lizenziert gemäß Apache Licence Version 2.0 (die „Lizenz“); Nutzung dieser - Datei nur in Übereinstimmung mit der Lizenz erlaubt. - Eine Kopie der Lizenz erhalten Sie auf http://www.apache.org/licenses/LICENSE-2.0. - - Sofern nicht gemäß geltendem Recht vorgeschrieben oder schriftlich vereinbart, - erfolgt die Bereitstellung der im Rahmen der Lizenz verbreiteten Software OHNE - GEWÄHR ODER VORBEHALTE – ganz gleich, ob ausdrücklich oder stillschweigend. - - Informationen über die jeweiligen Bedingungen für Genehmigungen und Einschränkungen - im Rahmen der Lizenz finden Sie in der Lizenz. - - Autor: Kai Huebl (kai@huebl-sgh.de) - - DESCRIPTION: - - The message transport publisher module receives a message from one ore more - network message writer groups via the internal message bus. The received message - is forwarded to the assigned communication module via the internal message bus. - - */ - -#ifndef __OpcUaStackPubSub_MsgTransPublisher_h__ -#define __OpcUaStackPubSub_MsgTransPublisher_h__ - -#include "OpcUaStackServer/ServiceSet/ServerServiceBase.h" - -namespace OpcUaStackPubSub -{ - - class DLLEXPORT MsgTransPublisher - : public OpcUaStackCore::Object - , public OpcUaStackServer::ServerServiceBase - { - public: - using SPtr = boost::shared_ptr; - - MsgTransPublisher( - const std::string& connectionName, // message bus member name - const std::string& serviceName, - OpcUaStackCore::IOThread::SPtr& ioThread, - OpcUaStackCore::MessageBus::SPtr& messageBus - ); - ~MsgTransPublisher(void); - - bool startup(void); - bool shutdown(void); - - private: - OpcUaStackCore::IOThread::SPtr ioThread_; // smart pointer to io thread - }; - -} - -#endif diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp b/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp deleted file mode 100644 index 1224dd191..000000000 --- a/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp +++ /dev/null @@ -1,112 +0,0 @@ -/* - Copyright 2022 Kai Huebl (kai@huebl-sgh.de) - - Lizenziert gemäß Apache Licence Version 2.0 (die „Lizenz“); Nutzung dieser - Datei nur in Übereinstimmung mit der Lizenz erlaubt. - Eine Kopie der Lizenz erhalten Sie auf http://www.apache.org/licenses/LICENSE-2.0. - - Sofern nicht gemäß geltendem Recht vorgeschrieben oder schriftlich vereinbart, - erfolgt die Bereitstellung der im Rahmen der Lizenz verbreiteten Software OHNE - GEWÄHR ODER VORBEHALTE – ganz gleich, ob ausdrücklich oder stillschweigend. - - Informationen über die jeweiligen Bedingungen für Genehmigungen und Einschränkungen - im Rahmen der Lizenz finden Sie in der Lizenz. - - Autor: Kai Huebl (kai@huebl-sgh.de) - */ -#include "OpcUaStackCore/Base/Log.h" -#include "OpcUaStackPubSub/Events/NetworkRecvEvent.h" -#include "OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.h" - -using namespace OpcUaStackCore; - -namespace OpcUaStackPubSub -{ - - MsgTransSubscriber::MsgTransSubscriber( - const std::string& serviceName, - OpcUaStackCore::IOThread::SPtr& ioThread, - OpcUaStackCore::MessageBus::SPtr& messageBus - ) - : ServerServiceBase() - { - // set parameter - ioThread_ = ioThread; - - // set parameter in server service base - serviceName_ = serviceName; - ServerServiceBase::ioThread_ = ioThread.get(); - strand_ = ioThread->createStrand(); - messageBus_ = messageBus; - - // register message bus receiver - MessageBusMemberConfig messageBusMemberConfig; - messageBusMemberConfig.strand(strand_); - messageBusMember_ = messageBus_->registerMember(serviceName_, messageBusMemberConfig); - - // activate receiver - activateReceiver( - [this](const MessageBusMember::WPtr& handleFrom, Message::SPtr& message) { - // receive message from internal message bus - - auto event = boost::static_pointer_cast(message); - switch (event->eventType()) - { - case EventType::NetworkRecvEvent: - { - NetworkRecvEvent::SPtr event = boost::static_pointer_cast(message); - // FIXME: todo - break; - } - default: - { - Log(Error, "invalid message received in message transport module") - .parameter("ServiceName", serviceName_) - .parameter("Event", (uint32_t)event->eventType()); - } - } - } - ); - } - - MsgTransSubscriber::~MsgTransSubscriber(void) - { - // deactivate receiver - deactivateReceiver(); - messageBus_->deregisterMember(messageBusMember_); - } - - bool - MsgTransSubscriber::startup(void) - { - // FIXME: todo - return true; - } - - bool - MsgTransSubscriber::shutdown(void) - { - // FIXME: todo - return true; - } - - bool - MsgTransSubscriber::registerNetworkMessageProcessor( - uint32_t publisherId, // publisher id - const std::string& networkMessageProcessorName // message bus member name - ) - { - // FIXME: todo - return true; - } - - bool - MsgTransSubscriber::deregisterNetworkMessageProcessor( - uint32_t publisherId - ) - { - // FIXME: todo - return true; - } - -} diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.h b/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.h deleted file mode 100644 index 43de15af5..000000000 --- a/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.h +++ /dev/null @@ -1,66 +0,0 @@ -/* - Copyright 2022 Kai Huebl (kai@huebl-sgh.de) - - Lizenziert gemäß Apache Licence Version 2.0 (die „Lizenz“); Nutzung dieser - Datei nur in Übereinstimmung mit der Lizenz erlaubt. - Eine Kopie der Lizenz erhalten Sie auf http://www.apache.org/licenses/LICENSE-2.0. - - Sofern nicht gemäß geltendem Recht vorgeschrieben oder schriftlich vereinbart, - erfolgt die Bereitstellung der im Rahmen der Lizenz verbreiteten Software OHNE - GEWÄHR ODER VORBEHALTE – ganz gleich, ob ausdrücklich oder stillschweigend. - - Informationen über die jeweiligen Bedingungen für Genehmigungen und Einschränkungen - im Rahmen der Lizenz finden Sie in der Lizenz. - - Autor: Kai Huebl (kai@huebl-sgh.de) - - DESCRIPTION: - - The message transport subscriber module receives a message from the communication - module via the internal message bus.The publisher ID is determined from the received - message and the assigned network message processor is determined. The received message - is forwarded to the assigned network message processor module via the internal message - bus. - - */ - -#ifndef __OpcUaStackPubSub_MsgTransSubscriber_h__ -#define __OpcUaStackPubSub_MsgTransSubscriber_h__ - -#include "OpcUaStackServer/ServiceSet/ServerServiceBase.h" - -namespace OpcUaStackPubSub -{ - - class DLLEXPORT MsgTransSubscriber - : public OpcUaStackCore::Object - , public OpcUaStackServer::ServerServiceBase - { - public: - using SPtr = boost::shared_ptr; - - MsgTransSubscriber( - const std::string& serviceName, - OpcUaStackCore::IOThread::SPtr& ioThread, - OpcUaStackCore::MessageBus::SPtr& messageBus - ); - ~MsgTransSubscriber(void); - - bool startup(void); - bool shutdown(void); - - bool registerNetworkMessageProcessor( - uint32_t publisherId, // publisher id - const std::string& networkMessageProcessorName // message bus member name - ); - bool deregisterNetworkMessageProcessor( - uint32_t publisherId - ); - - private: - OpcUaStackCore::IOThread::SPtr ioThread_; // smart pointer to io thread - }; - -} - -#endif