in src/workers/producer/start_or_shutdown.h [47:67]
void Execute()
{
try
{
switch(type) {
case START_PRODUCER:
ret = StartProducer(producer_ptr); break;
case SHUTDOWN_PRODUCER:
ret = ShutdownProducer(producer_ptr); break;
default: break;
}
}
catch(const runtime_error e)
{
SetErrorMessage(e.what());
}
catch(const exception& e)
{
SetErrorMessage(e.what());
}
}