Mergers: adapt to new FairMQ API for SendAsync and ReceiveAsync

Author: ktf

Utilities/QC/QCMerger/src/MergerDevice.cxx

@@ -208,13 +208,13 @@ TObject* MergerDevice::receiveDataObjectFromProducer()
   TObject* receivedDataObject;
   unique_ptr<FairMQMessage> input(NewMessage());
 
-  if ((respondeCode = fChannels.at("data-in").at(0).ReceiveAsync(input)) == -2) {
-    if ((respondeCode = fChannels.at("data-in").at(0).ReceiveAsync(input)) == -2) {
+  if ((respondeCode = fChannels.at("data-in").at(0).Receive(input, 0)) == -2) {
+    if ((respondeCode = fChannels.at("data-in").at(0).Receive(input, 0)) == -2) {
       mLastReceiveBufferOverloadTime = clock();
       mReceiveBufferOverloaded = true;
       LOG(DEBUG) << "Buffer of data-in channel is full. Waiting for free buffer...";
 
-      while ((respondeCode = fChannels.at("data-in").at(0).ReceiveAsync(input)) == -2) {
+      while ((respondeCode = fChannels.at("data-in").at(0).Receive(input, 0)) == -2) {
         this_thread::sleep_for(chrono::milliseconds(10));
       }
 

Utilities/QC/QCProducer/src/ProducerDevice.cxx

@@ -99,12 +99,12 @@ int ProducerDevice::getCurrentSecond() const
 
 void ProducerDevice::sendDataToMerger(unique_ptr<FairMQMessage> request)
 {
-  if (fChannels.at("data-out").at(0).SendAsync(request) == -2) {
+  if (fChannels.at("data-out").at(0).Send(request, 0) == -2) {
     mLastBufferOverloadTime = clock();
     mBufferOverloaded = true;
     LOG(DEBUG) << "Buffer of data-out channel is full. Waiting for free buffer...";
 
-    while (fChannels.at("data-out").at(0).SendAsync(request) == -2) {
+    while (fChannels.at("data-out").at(0).Send(request, 0) == -2) {
       this_thread::sleep_for(chrono::milliseconds(10));
     }
 

Utilities/QC/QCViewer/src/ViewerDevice.cxx

@@ -70,7 +70,7 @@ TObject* ViewerDevice::receiveDataObjectFromMerger()
   TObject* receivedObject;
   unique_ptr<FairMQMessage> request(NewMessage());
 
-  if (fChannels.at("data-in").at(0).ReceiveAsync(request) >= 0) {
+  if (fChannels.at("data-in").at(0).Receive(request, 0) >= 0) {
     TMessageWrapper tm(request->GetData(), request->GetSize());
     receivedObject = static_cast<TObject*>(tm.ReadObject(tm.GetClass()));
   } else {