diff --git a/src/algorithms/conditioner/adapters/array_signal_conditioner.cc b/src/algorithms/conditioner/adapters/array_signal_conditioner.cc
index d40adeb39..7e378516d 100644
--- a/src/algorithms/conditioner/adapters/array_signal_conditioner.cc
+++ b/src/algorithms/conditioner/adapters/array_signal_conditioner.cc
@@ -38,10 +38,9 @@ using google::LogMessage;
 // Constructor
 ArraySignalConditioner::ArraySignalConditioner(ConfigurationInterface *configuration,
         std::shared_ptr<GNSSBlockInterface> data_type_adapt, std::shared_ptr<GNSSBlockInterface> in_filt,
-        std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation,
-        boost::shared_ptr<gr::msg_queue> queue) : data_type_adapt_(data_type_adapt),
-                in_filt_(in_filt), res_(res), role_(role), implementation_(implementation),
-                queue_(queue)
+        std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation) :
+                data_type_adapt_(data_type_adapt),
+                in_filt_(in_filt), res_(res), role_(role), implementation_(implementation)
 {
     connected_ = false;
     if(configuration){ };
diff --git a/src/algorithms/conditioner/adapters/array_signal_conditioner.h b/src/algorithms/conditioner/adapters/array_signal_conditioner.h
index 1a635dabd..d0f100402 100644
--- a/src/algorithms/conditioner/adapters/array_signal_conditioner.h
+++ b/src/algorithms/conditioner/adapters/array_signal_conditioner.h
@@ -53,8 +53,7 @@ public:
     //! Constructor
     ArraySignalConditioner(ConfigurationInterface *configuration,
             std::shared_ptr<GNSSBlockInterface> data_type_adapt, std::shared_ptr<GNSSBlockInterface> in_filt,
-            std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation,
-            boost::shared_ptr<gr::msg_queue> queue);
+            std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation);
 
     //! Virtual destructor
     virtual ~ArraySignalConditioner();
@@ -81,7 +80,6 @@ private:
     std::string implementation_;
     bool connected_;
     //bool stop_;
-    boost::shared_ptr<gr::msg_queue> queue_;
 };
 
 #endif /*GNSS_SDR_SIGNAL_CONDITIONER_H_*/
diff --git a/src/algorithms/conditioner/adapters/signal_conditioner.cc b/src/algorithms/conditioner/adapters/signal_conditioner.cc
index 42feb8f40..962b0dac7 100644
--- a/src/algorithms/conditioner/adapters/signal_conditioner.cc
+++ b/src/algorithms/conditioner/adapters/signal_conditioner.cc
@@ -38,10 +38,9 @@ using google::LogMessage;
 // Constructor
 SignalConditioner::SignalConditioner(ConfigurationInterface *configuration,
         std::shared_ptr<GNSSBlockInterface> data_type_adapt, std::shared_ptr<GNSSBlockInterface> in_filt,
-        std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation,
-        boost::shared_ptr<gr::msg_queue> queue) : data_type_adapt_(data_type_adapt),
-                in_filt_(in_filt), res_(res), role_(role), implementation_(implementation),
-                queue_(queue)
+        std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation) :
+                data_type_adapt_(data_type_adapt),
+                in_filt_(in_filt), res_(res), role_(role), implementation_(implementation)
 {
     connected_ = false;
     if(configuration){ };
@@ -64,11 +63,10 @@ void SignalConditioner::connect(gr::top_block_sptr top_block)
     in_filt_->connect(top_block);
     res_->connect(top_block);
 
-    top_block->connect(data_type_adapt_->get_right_block(), 0,
-                       in_filt_->get_left_block(), 0);
+    top_block->connect(data_type_adapt_->get_right_block(), 0, in_filt_->get_left_block(), 0);
     DLOG(INFO) << "data_type_adapter -> input_filter";
-    top_block->connect(in_filt_->get_right_block(), 0,
-                       res_->get_left_block(), 0);
+
+    top_block->connect(in_filt_->get_right_block(), 0, res_->get_left_block(), 0);
     DLOG(INFO) << "input_filter -> resampler";
     connected_ = true;
 }
diff --git a/src/algorithms/conditioner/adapters/signal_conditioner.h b/src/algorithms/conditioner/adapters/signal_conditioner.h
index ef46a6491..de830368d 100644
--- a/src/algorithms/conditioner/adapters/signal_conditioner.h
+++ b/src/algorithms/conditioner/adapters/signal_conditioner.h
@@ -33,7 +33,6 @@
 #define GNSS_SDR_SIGNAL_CONDITIONER_H_
 
 #include <string>
-#include <gnuradio/msg_queue.h>
 #include "gnss_block_interface.h"
 
 
@@ -52,8 +51,7 @@ public:
     //! Constructor
     SignalConditioner(ConfigurationInterface *configuration,
             std::shared_ptr<GNSSBlockInterface> data_type_adapt, std::shared_ptr<GNSSBlockInterface> in_filt,
-            std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation,
-            boost::shared_ptr<gr::msg_queue> queue);
+            std::shared_ptr<GNSSBlockInterface> res, std::string role, std::string implementation);
 
     //! Virtual destructor
     virtual ~SignalConditioner();
@@ -80,7 +78,6 @@ private:
     std::string implementation_;
     bool connected_;
     //bool stop_;
-    boost::shared_ptr<gr::msg_queue> queue_;
 };
 
 #endif /*GNSS_SDR_SIGNAL_CONDITIONER_H_*/
diff --git a/src/core/receiver/gnss_block_factory.cc b/src/core/receiver/gnss_block_factory.cc
index 438238b24..3e5f22c2f 100644
--- a/src/core/receiver/gnss_block_factory.cc
+++ b/src/core/receiver/gnss_block_factory.cc
@@ -203,7 +203,7 @@ std::unique_ptr<GNSSBlockInterface> GNSSBlockFactory::GetSignalConditioner(
                 std::move(GetBlock(configuration, role_datatypeadapter, data_type_adapter, 1, 1, queue)), 
                 std::move(GetBlock(configuration, role_inputfilter, input_filter, 1, 1, queue)),
                 std::move(GetBlock(configuration, role_resampler, resampler, 1, 1, queue)),
-                role_conditioner, "Signal_Conditioner", queue));
+                role_conditioner, "Signal_Conditioner"));
             return conditioner_;
         }
     else
@@ -213,7 +213,7 @@ std::unique_ptr<GNSSBlockInterface> GNSSBlockFactory::GetSignalConditioner(
                 std::move(GetBlock(configuration, role_datatypeadapter, data_type_adapter, 1, 1, queue)), 
                 std::move(GetBlock(configuration, role_inputfilter, input_filter, 1, 1, queue)),
                 std::move(GetBlock(configuration, role_resampler, resampler, 1, 1, queue)),
-                role_conditioner, "Signal_Conditioner", queue));
+                role_conditioner, "Signal_Conditioner"));
             return conditioner_;
         }
 }