diff --git a/queue.php b/queue.php index b140267..6c12d12 100644 --- a/queue.php +++ b/queue.php @@ -16,6 +16,8 @@ class queue private $queue = null; /** Connect to the queue + * @param string $dsn The DSN to connect to queue + * @return $this; */ public function connect ($dsn) { @@ -24,10 +26,10 @@ class queue /** Add a new entry to the end of the queue * @param mixed $entry The entry to add + * @return $this; */ public function add ($entry) { - return $this; } @@ -36,10 +38,16 @@ class queue */ public function getAll () { + } + /** Get the number of entries in the queue + */ + public function count () + { } /** Clear all the entries of the queue + * @return $this; */ public function clear () { @@ -53,7 +61,6 @@ class queue */ public function getFirst ($delete = false) { - } /** Get the last entry in the queue with optional removing of the entry @@ -63,7 +70,6 @@ class queue */ public function getLast ($delete = false) { - } /** Get X entries starting at position Y @@ -74,6 +80,5 @@ class queue */ public function getRange ($start, $number, $delete = false) { - } } diff --git a/queuefile.php b/queuefile.php index 7248f1d..f639527 100644 --- a/queuefile.php +++ b/queuefile.php @@ -21,6 +21,8 @@ class queuefile extends queue private $queue = null; /** Connect to the queue. Create it if not exists + * @param string $dsn The DSN to connect to queue + * @return $this; */ public function connect ($dsn) // {{{ @@ -41,6 +43,7 @@ class queuefile extends queue /** Add a new entry to the end of the queue * @param mixed $entry The entry to add + * @return $this; */ public function add ($entry) // {{{ @@ -94,6 +97,7 @@ class queuefile extends queue // }}} /** Clear all the entries of the queue + * @return $this; */ public function clear () // {{{