A bit of a ture - switched lpush to rpush

Otherwise this works as a "last in, first out" queue.
justinrainbow · Jul 23, 2012 · fe3393e · fe3393e
1 parent f0ab355
commit fe3393e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/Presque/Storage/PhpredisStorage.php b/src/Presque/Storage/PhpredisStorage.php
@@ -38,7 +38,7 @@ public function getPrefix()
 
     public function push($listName, $payload)
     {
-        $this->connection->lPush($listName, json_encode($payload));
+        $this->connection->rPush($listName, json_encode($payload));
     }
 
     public function pop($listName, $waitTimeout = null)

diff --git a/src/Presque/Storage/PredisStorage.php b/src/Presque/Storage/PredisStorage.php
@@ -36,7 +36,7 @@ public function getPrefix()
 
     public function push($listName, $payload)
     {
-        $this->connection->lpush($this->getKey($listName), json_encode($payload));
+        $this->connection->rpush($this->getKey($listName), json_encode($payload));
     }
 
     public function pop($listName, $waitTimeout = null)

diff --git a/tests/Presque/Tests/Storage/PhpredisStorageTest.php b/tests/Presque/Tests/Storage/PhpredisStorageTest.php
@@ -29,7 +29,7 @@ public function testPushingDataOntoList()
 
         $this->redis
             ->expects($this->once())
-            ->method('lPush')
+            ->method('rPush')
             ->with($this->equalTo('list'), $this->equalTo(json_encode($payload)));
 
         $this->storage->push('list', $payload);

diff --git a/tests/Presque/Tests/Storage/PredisStorageTest.php b/tests/Presque/Tests/Storage/PredisStorageTest.php
@@ -28,7 +28,7 @@ public function testPushingDataOntoList()
         );
 
         $this->predis
-            ->shouldReceive('lpush')
+            ->shouldReceive('rpush')
             ->with('list', json_encode($payload))
             ->once();