void Execute()

in src/workers/producer/send_message.h [42:56]


    void Execute()
    {
        try
        {
            SendMessageSync(producer->GetProducer(), msg, &send_ret);
        }
        catch(const runtime_error e)
        {
            SetErrorMessage(e.what());
        }
        catch(const std::exception& e)
        {
            SetErrorMessage(e.what());
        }
    }