diff --git a/plugins/FakeDataProdModule.cpp b/plugins/FakeDataProdModule.cpp
index ce2f659..63ef718 100644
--- a/plugins/FakeDataProdModule.cpp
+++ b/plugins/FakeDataProdModule.cpp
@@ -162,7 +162,7 @@ FakeDataProdModule::do_timesync(std::atomic<bool>& running_flag)
 }
 
 void
-FakeDataProdModule::process_data_request(dfmessages::DataRequest& data_request)
+FakeDataProdModule::process_data_request(dfmessages::DataRequest&& data_request)
 {
 
   TLOG_DEBUG(TLVL_ENTER_EXIT_METHODS) << get_name() << ": processsing request " << data_request.request_number;
diff --git a/plugins/FakeDataProdModule.hpp b/plugins/FakeDataProdModule.hpp
index 571f525..8ac0ba2 100644
--- a/plugins/FakeDataProdModule.hpp
+++ b/plugins/FakeDataProdModule.hpp
@@ -73,7 +73,7 @@ class FakeDataProdModule : public dunedaq::appfwk::DAQModule
 
   // Threading
   dunedaq::utilities::WorkerThread m_timesync_thread;
-  void process_data_request(dfmessages::DataRequest&);
+  void process_data_request(dfmessages::DataRequest&&);
   void do_timesync(std::atomic<bool>&);
 
   // Configuration
diff --git a/plugins/FragmentAggregatorModule.cpp b/plugins/FragmentAggregatorModule.cpp
index 50a3b1a..4c5e51a 100644
--- a/plugins/FragmentAggregatorModule.cpp
+++ b/plugins/FragmentAggregatorModule.cpp
@@ -155,7 +155,7 @@ FragmentAggregatorModule::do_stop(const CommandData_t& /* args */)
 }
 
 void
-FragmentAggregatorModule::process_data_request(dfmessages::DataRequest& data_request)
+FragmentAggregatorModule::process_data_request(dfmessages::DataRequest&& data_request)
 {
 
   {
@@ -206,7 +206,7 @@ FragmentAggregatorModule::process_data_request(dfmessages::DataRequest& data_req
 }
 
 void
-FragmentAggregatorModule::process_fragment(std::unique_ptr<daqdataformats::Fragment>& fragment)
+FragmentAggregatorModule::process_fragment(std::unique_ptr<daqdataformats::Fragment>&& fragment)
 {
   // Forward Fragment to the right TRB
   std::string trb_identifier;
diff --git a/plugins/FragmentAggregatorModule.hpp b/plugins/FragmentAggregatorModule.hpp
index 4ebcc98..850996e 100644
--- a/plugins/FragmentAggregatorModule.hpp
+++ b/plugins/FragmentAggregatorModule.hpp
@@ -69,8 +69,8 @@ class FragmentAggregatorModule : public dunedaq::appfwk::DAQModule
   void do_start(const CommandData_t& obj);
   void do_stop(const CommandData_t& obj);
 
-  void process_data_request(dfmessages::DataRequest&);
-  void process_fragment(std::unique_ptr<daqdataformats::Fragment>&);
+  void process_data_request(dfmessages::DataRequest&&);
+  void process_fragment(std::unique_ptr<daqdataformats::Fragment>&&);
 
   // Input and Output Connection names
   std::string m_data_req_input;
diff --git a/plugins/TRBModule.cpp b/plugins/TRBModule.cpp
index 29bc338..6633bcd 100644
--- a/plugins/TRBModule.cpp
+++ b/plugins/TRBModule.cpp
@@ -279,7 +279,7 @@ TRBModule::do_stop(const CommandData_t& /*args*/)
 }
 
 void
-TRBModule::tr_requested(const dfmessages::TRMonRequest& req)
+TRBModule::tr_requested(const dfmessages::TRMonRequest&& req)
 {
   ++m_trmon_request_counter;
 
@@ -328,7 +328,7 @@ TRBModule::flush_trigger_records()
 } // NOLINT(readability/fn_size)
 
 void
-TRBModule::fragments_callback(std::unique_ptr<daqdataformats::Fragment>& temp_fragment)
+TRBModule::fragments_callback(std::unique_ptr<daqdataformats::Fragment>&& temp_fragment)
 {
 
   auto start_time = std::chrono::steady_clock::now();
@@ -428,7 +428,7 @@ TRBModule::fragments_callback(std::unique_ptr<daqdataformats::Fragment>& temp_fr
 }
 
 void
-TRBModule::trigger_decision_callback(dfmessages::TriggerDecision& td)
+TRBModule::trigger_decision_callback(dfmessages::TriggerDecision&& td)
 {
 
   auto start_time = std::chrono::steady_clock::now();
diff --git a/plugins/TRBModule.hpp b/plugins/TRBModule.hpp
index cd2795a..5a867ae 100644
--- a/plugins/TRBModule.hpp
+++ b/plugins/TRBModule.hpp
@@ -195,8 +195,8 @@ class TRBModule : public dunedaq::appfwk::DAQModule
   using trigger_record_ptr_t = std::unique_ptr<daqdataformats::TriggerRecord>;
   using trigger_record_sender_t = iomanager::SenderConcept<trigger_record_ptr_t>;
 
-  void trigger_decision_callback(dfmessages::TriggerDecision& td);
-  void fragments_callback(std::unique_ptr<daqdataformats::Fragment>& frag);
+  void trigger_decision_callback(dfmessages::TriggerDecision&& td);
+  void fragments_callback(std::unique_ptr<daqdataformats::Fragment>&& frag);
 
   trigger_record_ptr_t extract_trigger_record(const TriggerId&);
   // build_trigger_record will allocate memory and then orphan it to the caller
@@ -224,7 +224,7 @@ class TRBModule : public dunedaq::appfwk::DAQModule
   void do_stop(const CommandData_t&);
 
   // Monitoring callback
-  void tr_requested(const dfmessages::TRMonRequest &);
+  void tr_requested(const dfmessages::TRMonRequest &&);
 
   // Threading
   std::atomic<bool> m_stop_requested;