Preserve tasks order

bazilio91 · Jul 27, 2015 · 438bb43 · 438bb43
1 parent 92b1604
commit 438bb43
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/transports/AsyncRedisTransport.php b/transports/AsyncRedisTransport.php
@@ -33,7 +33,7 @@ public static function getQueueKey($queueName, $progress = false)
      */
     public function send($text, $queueName)
     {
-        $return = $this->connection->executeCommand('RPUSH', [self::getQueueKey($queueName), $text]);
+        $return = $this->connection->executeCommand('LPUSH', [self::getQueueKey($queueName), $text]);
         $this->connection->executeCommand('PUBLISH', [self::getQueueKey($queueName), 'new']);
         return $return;
     }
@@ -127,4 +127,4 @@ function disconnect()
             $this->connection->close();
         }
     }
-}
+}