core rc2-final

1 files changed, 5 insertions, 4 deletions

diff --git a/op25/gr-op25_repeater/lib/frame_assembler_impl.cc b/op25/gr-op25_repeater/lib/frame_assembler_impl.cc
index d40c33e..8f0f3ca 100644
--- a/op25/gr-op25_repeater/lib/frame_assembler_impl.cc
+++ b/op25/gr-op25_repeater/lib/frame_assembler_impl.cc
@@ -54,10 +54,10 @@ namespace gr {
     }
 
     frame_assembler::sptr
-    frame_assembler::make(const char* options, int debug, gr::msg_queue::sptr queue)
+    frame_assembler::make(const char* options, int debug, gr::msg_queue::sptr queue, int msgq_id)
     {
       return gnuradio::get_initial_sptr
-        (new frame_assembler_impl(options, debug, queue));
+        (new frame_assembler_impl(options, debug, queue, msgq_id));
     }
 
     /*
@@ -77,12 +77,13 @@ static const int MAX_IN = 1;	// maximum number of input streams
 /*
  * The private constructor
  */
-    frame_assembler_impl::frame_assembler_impl(const char* options, int debug, gr::msg_queue::sptr queue)
+    frame_assembler_impl::frame_assembler_impl(const char* options, int debug, gr::msg_queue::sptr queue, int msgq_id)
       : gr::block("frame_assembler",
 		   gr::io_signature::make (MIN_IN, MAX_IN, sizeof (char)),
 		   gr::io_signature::make (0, 0, 0)),
 	d_msg_queue(queue),
-	d_sync(options, debug, queue)
+	d_sync(options, debug, queue, msgq_id),
+	d_msgq_id(msgq_id)
 {
 }