Method receiver

cpp/examples/multithreaded_client_flow_control.cpp:165–172

Connect to url

    // Connect to url
    receiver(proton::container& cont, const std::string& url, const std::string& address)
        : work_queue_(0), closed_(false)
    {
        // NOTE:credit_window(0) disables automatic flow control.
        // We will use flow control to match AMQP credit to buffer capacity.
        cont.open_receiver(url+"/"+address, proton::receiver_options().credit_window(0),
                           proton::connection_options().handler(*this));
    }

    // Thread safe receive
    proton::message receive() {