From f522dc17171ffedc8510b8363e3422596c2c3113 Mon Sep 17 00:00:00 2001
From: Dennis Klein <d.klein@gsi.de>
Date: Sat, 13 May 2017 16:54:56 +0200
Subject: [PATCH] add FairMQParts Send/Receive apis

---
 fairmq/FairMQChannel.h | 34 +++++++++++++++++++++++++++++++---
 1 file changed, 31 insertions(+), 3 deletions(-)

diff --git a/fairmq/FairMQChannel.h b/fairmq/FairMQChannel.h
index 95c1de67..386ce186 100644
--- a/fairmq/FairMQChannel.h
+++ b/fairmq/FairMQChannel.h
@@ -26,9 +26,7 @@
 #include "FairMQPoller.h"
 #include "FairMQTransports.h"
 #include "FairMQLogger.h"
-
-class FairMQPoller;
-class FairMQTransportFactory;
+#include "FairMQParts.h"
 
 class FairMQChannel
 {
@@ -222,6 +220,36 @@ class FairMQChannel
     /// In case of errors, returns -1.
     int64_t ReceiveAsync(std::vector<std::unique_ptr<FairMQMessage>>& msgVec) const;
 
+    int64_t Send(FairMQParts& parts) const
+    {
+        return Send(parts.fParts);
+    }
+
+    int64_t Receive(FairMQParts& parts) const
+    {
+        return Receive(parts.fParts);
+    }
+
+    int64_t Send(FairMQParts& parts, int sndTimeoutInMs) const
+    {
+        return Send(parts.fParts, sndTimeoutInMs);
+    }
+
+    int64_t Receive(FairMQParts& parts, int rcvTimeoutInMs) const
+    {
+        return Receive(parts.fParts, rcvTimeoutInMs);
+    }
+
+    int64_t SendAsync(FairMQParts& parts) const
+    {
+        return SendAsync(parts.fParts);
+    }
+
+    int64_t ReceiveAsync(FairMQParts& parts) const
+    {
+        return ReceiveAsync(parts.fParts);
+    }
+
     // TODO: this might go to some base utility library
     static void Tokenize(std::vector<std::string>& output, const std::string& input, const std::string delimiters = ",");