Class Handler

phxqueue/comm/handler.h:29–41

};

class Handler {
  public:
    Handler() {}
    virtual ~Handler() {}

    virtual HandleResult Handle(const proto::ConsumerContext &cc, proto::QItem &item, std::string &uncompressed_buffer) = 0;

    void SetBufferUpdated(bool buffer_updated) {buffer_updated_ = buffer_updated;}
    bool IsBufferUpdated() { return buffer_updated_; }

  private:
    bool buffer_updated_{false};
};

template <class T>
class PBHandler : public Handler {