added shell consumer

CMakeLists.txt

@@ -68,6 +68,7 @@ include_directories(
 
 add_library(ur_rtde_driver
     src/comm/tcp_socket.cpp
+    src/comm/shell_consumer.cpp
     #src/ros/service_stopper.cpp
     #src/ur/commander.cpp
     #src/ur/master_board.cpp

include/ur_rtde_driver/comm/shell_consumer.h

@@ -0,0 +1,52 @@
+// this is for emacs file handling -*- mode: c++; indent-tabs-mode: nil -*-
+
+// -- BEGIN LICENSE BLOCK ----------------------------------------------
+// -- END LICENSE BLOCK ------------------------------------------------
+
+//----------------------------------------------------------------------
+/*!\file
+ *
+ * \author  Felix Mauch mauch@fzi.de
+ * \date    2019-04-09
+ *
+ */
+//----------------------------------------------------------------------
+
+#ifndef UR_RTDE_DRIVER_SHELL_CONSUMER_H_INCLUDED
+#define UR_RTDE_DRIVER_SHELL_CONSUMER_H_INCLUDED
+
+#include "ur_rtde_driver/comm/pipeline.h"
+#include "ur_rtde_driver/comm/package.h"
+
+namespace ur_driver
+{
+namespace comm
+{
+template <typename HeaderT>
+class ShellConsumer : public IConsumer<URPackage<HeaderT>>
+{
+public:
+  ShellConsumer() = default;
+  virtual ~ShellConsumer() = default;
+
+  virtual void setupConsumer()
+  {
+  }
+  virtual void teardownConsumer()
+  {
+  }
+  virtual void stopConsumer()
+  {
+  }
+  virtual void onTimeout()
+  {
+  }
+
+  virtual bool consume(std::shared_ptr<URPackage<HeaderT>> product);
+
+private:
+  /* data */
+};
+}  // namespace comm
+}  // namespace ur_driver
+#endif  // ifndef UR_RTDE_DRIVER_SHELL_CONSUMER_H_INCLUDED

src/comm/shell_consumer.cpp

@@ -0,0 +1,29 @@
+// this is for emacs file handling -*- mode: c++; indent-tabs-mode: nil -*-
+
+// -- BEGIN LICENSE BLOCK ----------------------------------------------
+// -- END LICENSE BLOCK ------------------------------------------------
+
+//----------------------------------------------------------------------
+/*!\file
+ *
+ * \author  Felix Mauch mauch@fzi.de
+ * \date    2019-04-09
+ *
+ */
+//----------------------------------------------------------------------
+
+#include "ur_rtde_driver/comm/shell_consumer.h"
+
+namespace ur_driver
+{
+namespace comm
+{
+template <typename HeaderT>
+bool ShellConsumer<HeaderT>::consume(std::shared_ptr<URPackage<HeaderT>> pkg)
+{
+  LOG_INFO("%s", pkg->toString());
+  return true;
+}
+}  // namespace comm
+
+}  // namespace ur_driver