void Execute()

in src/workers/push_consumer/start_or_shutdown.h [47:67]


    void Execute()
    {
        try
        {
            switch(type) {
            case START_PUSH_CONSUMER:
                ret = StartPushConsumer(consumer_ptr); break;
            case SHUTDOWN_PUSH_CONSUMER:
                ret = ShutdownPushConsumer(consumer_ptr); break;
            default: break;
            }
        }
        catch(const runtime_error e)
        {
            SetErrorMessage(e.what());
        }
        catch(const exception& e)
        {
            SetErrorMessage(e.what());
        }
    }