add receiver function

ASNeG · Jan 22, 2023 · db57b08 · db57b08
1 parent 73700ef
commit db57b08
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 2 deletions.
diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp b/src/OpcUaStackPubSub/MessageTransport/MsgTransPublisher.cpp
@@ -15,6 +15,8 @@
    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;
@@ -49,7 +51,22 @@ namespace OpcUaStackPubSub
 			[this](const MessageBusMember::WPtr& handleFrom, Message::SPtr& message) {
 				// receive message from internal message bus
 
-				// FIXME: todo
+				auto event = boost::static_pointer_cast<Event>(message);
+				switch (event->eventType())
+				{
+					case EventType::NetworkSendEvent:
+					{
+						NetworkSendEvent::SPtr event = boost::static_pointer_cast<NetworkSendEvent>(message);
+						// FIXME: todo
+						break;
+					}
+					default:
+					{
+						Log(Error, "invalid message received in message transport module")
+							.parameter("ServiceName", serviceName_)
+							.parameter("Event", (uint32_t)event->eventType());
+					}
+				}
 			}
 		);
 	}

diff --git a/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp b/src/OpcUaStackPubSub/MessageTransport/MsgTransSubscriber.cpp
@@ -15,6 +15,7 @@
    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;
@@ -48,7 +49,22 @@ namespace OpcUaStackPubSub
 			[this](const MessageBusMember::WPtr& handleFrom, Message::SPtr& message) {
 				// receive message from internal message bus
 
-				// FIXME: todo
+				auto event = boost::static_pointer_cast<Event>(message);
+				switch (event->eventType())
+				{
+					case EventType::NetworkRecvEvent:
+					{
+						NetworkRecvEvent::SPtr event = boost::static_pointer_cast<NetworkRecvEvent>(message);
+						// FIXME: todo
+						break;
+					}
+					default:
+					{
+						Log(Error, "invalid message received in message transport module")
+							.parameter("ServiceName", serviceName_)
+							.parameter("Event", (uint32_t)event->eventType());
+					}
+				}
 			}
 		);
 	}