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());
}
}