Method getInputQueue

src/IOThread.cpp:85–88

}

ThreadQueueBasePtr IOThread::getInputQueue(const std::string& qname) {
    std::lock_guard < std::mutex > lock(m_queue_bindings_mutex);
    return input_queues[qname];
}

void IOThread::setOutputQueue(const std::string& qname, const ThreadQueueBasePtr& threadQueue) {
    std::lock_guard < std::mutex > lock(m_queue_bindings_mutex);