From 835c88c6d234fb0e59bed51d4b7abb8cf7cca1f4 Mon Sep 17 00:00:00 2001
From: winckler <n.winckler@gsi.de>
Date: Mon, 28 Mar 2016 19:13:49 +0200
Subject: [PATCH] change serialization API so that it takes a FairMQMessage
 reference

---
 fairmq/FairMQDevice.h | 11 ++++++-----
 fairmq/FairMQParts.h  |  3 +++
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/fairmq/FairMQDevice.h b/fairmq/FairMQDevice.h
index 7a85e358..93098f39 100644
--- a/fairmq/FairMQDevice.h
+++ b/fairmq/FairMQDevice.h
@@ -98,19 +98,20 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
     }
 
 //*
-    template<typename Serializer, typename MessageType, typename DataType, typename... Args>
-    void Serialize(std::unique_ptr<FairMQMessage>& msg, DataType&& data, Args&&... args) const
+    template<typename Serializer, typename DataType, typename... Args>
+    void Serialize(FairMQMessage& msg, DataType&& data, Args&&... args) const
     {
         Serializer().Serialize(msg,std::forward<DataType>(data),std::forward<Args>(args)...);
     }
 
     template<typename Deserializer, typename DataType, typename... Args>
-    void Deserialize(std::unique_ptr<FairMQMessage>& msg, DataType&& data, Args&&... args) const
+    void Deserialize(FairMQMessage& msg, DataType&& data, Args&&... args) const
     {
         Deserializer().Deserialize(msg,std::forward<DataType>(data),std::forward<Args>(args)...);
     }
-// */
 
+
+/*
 // temporary overload to handle the case of a return ref to FairMQMessage
     template<typename Serializer, typename MessageType, typename DataType>
     void Serialize(MessageType&& msg, DataType&& data) const
@@ -124,7 +125,7 @@ class FairMQDevice : public FairMQStateMachine, public FairMQConfigurable
         Deserializer().Deserialize(std::forward<MessageType>(msg), std::forward<DataType>(data));
     }
 
-
+// */
 
 
     /// Shorthand method to receive `msg` on `chan` at index `i`
diff --git a/fairmq/FairMQParts.h b/fairmq/FairMQParts.h
index dc2ad793..453427a1 100644
--- a/fairmq/FairMQParts.h
+++ b/fairmq/FairMQParts.h
@@ -81,6 +81,9 @@ class FairMQParts
     /// @param index container index
     inline std::unique_ptr<FairMQMessage>& At(const int index) { return fParts.at(index); }
 
+
+    inline FairMQMessage& At_ref(const int index) { return *(fParts.at(index)); }
+
     template<typename Deserializer, typename DataType>
     inline void At(DataType&& data, const int index)
     {