Change purge timeout

overblog · Dec 9, 2014 · 4899d91 · 4899d91
1 parent d4e1762
commit 4899d91
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ActiveMq/Connection.php b/ActiveMq/Connection.php
@@ -130,8 +130,8 @@ public function purge($queue)
         $stomp = $this->getConnection();
         $header = array('id' => sprintf('purge:%s', $queue));
 
-        // No need to wait more than 1 ms if there is no messages in queue
-        $stomp->setReadTimeout(0, 1);
+        // No need to wait more than 1s if there is no messages in queue
+        $stomp->setReadTimeout(1, 0);
 
         $stomp->subscribe($queue, $header);