diff --git a/fairmq/devices/GenericSampler.h b/fairmq/devices/GenericSampler.h index adb1f817..8068ce56 100644 --- a/fairmq/devices/GenericSampler.h +++ b/fairmq/devices/GenericSampler.h @@ -80,7 +80,8 @@ class base_GenericSampler : public FairMQDevice, public T, public U { std::unique_ptr msg(NewMessage()); T::Deserialize(idx); - Send(fInput, fOutChanName); + Serialize(msg,fInput); + Send(msg, fOutChanName); sentMsgs++; if (!CheckCurrentState(RUNNING)) break;