Method setOutputQueue

src/IOThread.cpp:90–94

}

void IOThread::setOutputQueue(const std::string& qname, const ThreadQueueBasePtr& threadQueue) {
    std::lock_guard < std::mutex > lock(m_queue_bindings_mutex);
    output_queues[qname] = threadQueue;
    this->onBindOutput(qname, threadQueue);
}

ThreadQueueBasePtr IOThread::getOutputQueue(const std::string& qname) {
    std::lock_guard < std::mutex > lock(m_queue_bindings_mutex);