diff --git a/transports/AsyncRedisTransport.php b/transports/AsyncRedisTransport.php index 0ae94ae..6d4d9ce 100644 --- 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(); } } -} \ No newline at end of file +}