Method AfterGet

phxqueue/consumer/consumer.h:143–143

Callback after the pull thread finished get items from Store.

    // Callback after the pull thread finished get items from Store.
    virtual void AfterGet(const comm::proto::GetRequest &req, const comm::proto::GetResponse &resp) {}

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