MCPcopy Create free account
hub / github.com/Tencent/phxqueue / AfterAdd

Method AfterAdd

phxqueue/consumer/consumer.h:149–149  ·  view source on GitHub ↗

Callback after the pull thread finished add items to Store.

Source from the content-addressed store, hash-verified

147
148 // Callback after the pull thread finished add items to Store.
149 virtual void AfterAdd(const comm::proto::AddRequest &req, const comm::proto::AddResponse &resp) {}
150
151 // Callback after the consume thread finished consume.
152 // e.g. For add items to retry queue.

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected