| 24 | |
| 25 | |
| 26 | int main(int argc, char **argv) { |
| 27 | comm::LogFunc log_func; |
| 28 | plugin::LoggerGoogle::GetLogger("test_consumer", "/tmp/phxqueue/log", 3, log_func); |
| 29 | |
| 30 | consumer::ConsumerOption opt; |
| 31 | opt.topic = "test"; |
| 32 | opt.ip = "127.0.0.1"; |
| 33 | opt.port = 8001; |
| 34 | opt.nprocs = 3; |
| 35 | opt.proc_pid_path = "/tmp/phxqueue/"; |
| 36 | opt.lock_path_base = "./phxqueueconsumer.lock."; |
| 37 | opt.log_func = log_func; |
| 38 | |
| 39 | test::SimpleConsumer consumer(opt); |
| 40 | consumer.AddHandlerFactory(1, new comm::DefaultHandlerFactory<test::SimpleHandler>()); |
| 41 | consumer.Run(); |
| 42 | |
| 43 | return 0; |
| 44 | } |
| 45 |
nothing calls this directly
no test coverage detected