Message Consumer_receive_timeout()

in src/consumer.cc [35:43]

• 8 lines of code
• 1 McCabe index (conditional complexity)

Message Consumer_receive_timeout(Consumer& consumer, int timeoutMs) {
    Message msg;
    Result res;
    Py_BEGIN_ALLOW_THREADS res = consumer.receive(msg, timeoutMs);
    Py_END_ALLOW_THREADS

        CHECK_RESULT(res);
    return msg;
}