dev

helper/queue/iqueue.php

@@ -303,6 +303,8 @@ abstract class ILooper
 
     public function run()
     {
+        refill\RefillFactory::instance();
+
         $this->_cid = Swoole\Coroutine::getCid();
         Log::record("runloop cid={$this->_cid}",Log::DEBUG);