--- a/src/DIF/RMT/RMTQueueManager.cc
+++ b/src/DIF/RMT/RMTQueueManager.cc
@@ -27,6 +27,11 @@
RMTQueueManager::~RMTQueueManager()
{
+}
+
+void RMTQueueManager::initialize()
+{
+ qMonPolicy = ModuleAccess<RMTQMonitorBase>("queueMonitorPolicy").get();
}
@@ -81,6 +86,10 @@
module->getOutputGate()->connectTo(rmtIn);
}
+ module->redrawGUI();
+
+ qMonPolicy->postQueueCreation(module);
+
module->setType(type);
queues.push_back(module);
return module;
@@ -116,6 +125,8 @@
++i;
}
}
+
+ qMonPolicy->preQueueRemoval(queue);
queue->deleteModule();
}