dev

helper/queue/iqueue.php

@@ -264,7 +264,7 @@ abstract class ILooper
 
     public function run()
     {
-        $this->_cid = Swoole\Coroutine::getPcid();
+        $this->_cid = Swoole\Coroutine::getCid();
         Log::record("runloop cid={$this->_cid}",Log::DEBUG);
 
         $queues = $this->mServer->scan();

rdispatcher/coall.php

@@ -83,7 +83,7 @@ function subscribe_message(&$quit, &$redis, $channels,$looper)
                 if($type == 'channel' || $type == 'merchant') {
                     $looper->pause();
                     Log::record("start load.....",Log::DEBUG);
-//                    refill\RefillFactory::instance()->load();
+                    refill\RefillFactory::instance()->load();
                     Log::record("fini load.....",Log::DEBUG);
                     $looper->resume();
                 }