Method BeforeGet

phxqueue/consumer/consumer.h:140–140

Callback before the pull thread start get items from Store.

    // Callback before the pull thread start get items from Store.
    virtual void BeforeGet(const comm::proto::GetRequest &req) {}

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