Preserve tasks order

bazilio91 · bazilio91 · commit 438bb430f5cf · 2015-07-27T14:20:38.000+05:00
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();
         }
     }
-}
+}

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ public static function getQueueKey($queueName, $progress = false)`
`33`	`33`	`*/`
`34`	`34`	`public function send($text, $queueName)`
`35`	`35`	`{`
`36`		`- $return = $this->connection->executeCommand('RPUSH', [self::getQueueKey($queueName), $text]);`
	`36`	`+ $return = $this->connection->executeCommand('LPUSH', [self::getQueueKey($queueName), $text]);`
`37`	`37`	`$this->connection->executeCommand('PUBLISH', [self::getQueueKey($queueName), 'new']);`
`38`	`38`	`return $return;`
`39`	`39`	`}`
`@@ -127,4 +127,4 @@ function disconnect()`
`127`	`127`	`$this->connection->close();`
`128`	`128`	`}`
`129`	`129`	`}`
`130`		`-}`
	`130`	`+}`