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

Method OnProcess

phxqueue/comm/breakpoint.h:38–38  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

36 virtual void OnLock(const int topic_id) {}
37 virtual void OnLockSucc(const proto::ConsumerContext &cc) {}
38 virtual void OnProcess(const proto::ConsumerContext &cc) {}
39 virtual void OnProcessFail(const proto::ConsumerContext &cc) {}
40 virtual void OnProcessSucc(const proto::ConsumerContext &cc) {}
41 virtual void OnGetQueueDelayFail(const proto::ConsumerContext &cc) {}

Callers 1

ChildRunMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected