move keep alive

siosphere · Nov 28, 2016 · 4f5cfe8 · 4f5cfe8
1 parent 3d26a21
commit 4f5cfe8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Virge/Graphite/Service/QueueService.php b/Virge/Graphite/Service/QueueService.php
@@ -62,17 +62,17 @@ public function listen($queue, $callback) {
         };*/
 
         $this->getChannel()->basic_consume($queue, '', false, false, false, false, function($message) use($callback) {
+            $this->keepAliveCallback();
             $task = unserialize($message->body);
             call_user_func($callback, $task);
 
             $this->complete($message);
         });
         while(count($this->getChannel()->callbacks)) {
             try {
-                $this->getChannel()->wait(null, false, Config::get('queue', 'wait_timeout'));
+                $this->getChannel()->wait();
             } catch (\PhpAmqpLib\Exception\AMQPTimeoutException $timeout) {
             }
-            $this->keepAliveCallback();
         }
     }