mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
0a329ba627
* Refector PopLongPollingService * Use enum PollingResult to replace int value * Move PopLongPollingService to upper level * Move wakeUp and polling method into PopLongPollingService * NotificationProcessor use PopLongPollingService * Add BORN_TIME check * add NotificationIT