Method BeforeAdd

phxqueue/consumer/consumer.h:146–146

Callback before the pull thread start add items to Store.

    // Callback before the pull thread start add items to Store.
    virtual void BeforeAdd(const comm::proto::AddRequest &req) {}

    // Callback after the pull thread finished add items to Store.
    virtual void AfterAdd(const comm::proto::AddRequest &req, const comm::proto::AddResponse &resp) {}