fix: Adopt fair::mq::Device::GetChannels() API

Since FairMQ 1.5.0:
```
warning: ‘fair::mq::Device::fChannels’ is deprecated: Use GetChannels() instead.
```
see FairRootGroup/FairMQ@5ef17fd

FairMQ 1.4 is still supported, so we need to maintain a switch.

Author: dennisklein

examples/MQ/histogramServer/FairMQExHistoDevice.cxx

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (C) 2014-2022 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
+ * Copyright (C) 2014-2024 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
  *                                                                              *
  *              This software is distributed under the terms of the             *
  *              GNU Lesser General Public Licence (LGPL) version 3,             *
@@ -8,6 +8,7 @@
 
 #include "FairMQExHistoDevice.h"
 
+#include "FairMQ.h"
 #include "RootSerializer.h"
 
 #include <TMath.h>
@@ -55,7 +56,7 @@ bool FairMQExHistoDevice::ConditionalRun()
     auto message(NewMessage());
     RootSerializer().Serialize(*message, &fArrayHisto);
 
-    for (auto& channel : fChannels) {
+    for (auto& channel : fairroot::GetFairMQDeviceChannels(*this)) {
         Send(message, channel.first);
     }
 

examples/MQ/pixelDetector/src/devices/FairMQRunDevice.cxx

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (C) 2014-2023 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
+ * Copyright (C) 2014-2024 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
  *                                                                              *
  *              This software is distributed under the terms of the             *
  *         GNU Lesser General Public Licence version 3 (LGPL) version 3,        *
@@ -14,6 +14,7 @@
 
 #include "FairMQRunDevice.h"
 
+#include "FairMQ.h"
 #include "FairOnlineSink.h"
 #include "FairRootManager.h"
 #include "RootSerializer.h"
@@ -23,7 +24,6 @@
 #include <TObjString.h>
 #include <cstdio>   // printf
 #include <fairlogger/Logger.h>
-
 #include <mutex>   // std::mutex
 std::mutex mtx;    // mutex for critical section
 
@@ -66,7 +66,7 @@ void FairMQRunDevice::SendBranches(FairOnlineSink& sink)
 
     TList* branchNameList = FairRootManager::Instance()->GetBranchNameList();
 
-    for (auto& mi : fChannels) {
+    for (auto& mi : fairroot::GetFairMQDeviceChannels(*this)) {
         LOG(debug) << "trying channel >" << mi.first << "<";
 
         fair::mq::Parts parts;

fairroot/basemq/devices/FairMQLmdSampler.h

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (C) 2014-2022 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
+ * Copyright (C) 2014-2024 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
  *                                                                              *
  *              This software is distributed under the terms of the             *
  *              GNU Lesser General Public Licence (LGPL) version 3,             *
@@ -245,8 +245,8 @@ class FairMQLmdSampler : public fair::mq::Device
                 fair::mq::Parts parts;
 
                 // send header
-                // auto header(fTransportFactory->CreateMessage(fSubEvent, sizeof(fSubEvent),
-                // free_buffer, nullptr)); fChannels.at(chanName).at(0).SendPart(header);
+                // auto header(fTransportFactory->CreateMessage(fSubEvent, sizeof(fSubEvent), free_buffer, nullptr));
+                // GetChannel(chanName, 0).SendPart(header);
 
                 int* arraySize = new int(sebuflength);
 

fairroot/basemq/devices/FairMQUnpacker.h

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (C) 2014-2022 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
+ * Copyright (C) 2014-2024 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
  *                                                                              *
  *              This software is distributed under the terms of the             *
  *              GNU Lesser General Public Licence (LGPL) version 3,             *
@@ -88,7 +88,9 @@ class FairMQUnpacker : public fair::mq::Device
         }
 
         // check if given channel exist
-        if (!fChannels.count(fInputChannelName)) {
+        try {
+            GetChannel(fInputChannelName);
+        } catch (const std::out_of_range&) {
             throw std::runtime_error(std::string("MQ-channel name '") + fInputChannelName
                                      + "' does not exist. Check the MQ-channel configuration");
         }
@@ -105,7 +107,7 @@ class FairMQUnpacker : public fair::mq::Device
 
     void Run()
     {
-        fair::mq::Channel& inputChannel = fChannels.at(fInputChannelName).at(0);
+        auto& inputChannel = GetChannel(fInputChannelName);
 
         while (!NewStatePending()) {
             auto msgSize(NewMessage());

fairroot/fairmq/FairMQ.h

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (C) 2022-2023 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
+ * Copyright (C) 2022-2024 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH  *
  *                                                                              *
  *              This software is distributed under the terms of the             *
  *              GNU Lesser General Public Licence (LGPL) version 3,             *
@@ -53,4 +53,19 @@ using TransportFactory = ::FairMQTransportFactory;
 
 #endif
 
+namespace fairroot
+{
+
+// see https://github.com/FairRootGroup/FairMQ/commit/5ef17fddbb6a957867cd6aca978176bc95c63508
+inline auto& GetFairMQDeviceChannels(fair::mq::Device& device)
+{
+#if FAIRMQ_VERSION_DEC < 105000
+    return device.fChannels;
+#else
+    return device.GetChannels();
+#endif
+}
+
+}   // namespace fairroot
+
 #endif   // FAIRROOT_FAIRMQ_H