| 28 | |
| 29 | |
| 30 | comm::HandleResult EchoHandler::Handle(const comm::proto::ConsumerContext &cc, |
| 31 | comm::proto::QItem &item, string &uncompressed_buffer) { |
| 32 | printf("consume echo \"%s\" succeeded! sub_id %d store_id %d queue_id %d item_uin %" PRIu64 "\n", |
| 33 | item.buffer().c_str(), cc.sub_id(), cc.store_id(), cc.queue_id(), (uint64_t)item.meta().uin()); |
| 34 | fflush(stdout); |
| 35 | return comm::HandleResult::RES_OK; |
| 36 | } |
| 37 | |
| 38 | |
| 39 | } // namespace test |
nothing calls this directly
no outgoing calls
no test coverage detected