Merge pull request #10 from queue-interop/basic-consume

Add basic consume methods.

Author: makasim

src/AmqpContext.php

@@ -57,4 +57,34 @@ public function unbind(AmqpBind $bind);
      * @param bool $global
      */
     public function setQos($prefetchSize, $prefetchCount, $global);
+
+    /**
+     * Notify broker that the channel is interested in consuming messages from this queue.
+     *
+     * A callback function to which the consumed message will be passed.
+     * The function must accept at a minimum one parameter, an \Interop\Amqp\AmqpMessage object,
+     * and an optional second parameter the \Interop\Amqp\AmqpConsumer from which the message was
+     * consumed. The \Interop\Amqp\AmqpContext::basicConsume() will not return the processing thread back to
+     * the PHP script until the callback function returns FALSE.
+     *
+     * @param AmqpConsumer $consumer
+     * @param callable     $callback
+     *
+     * @return void
+     */
+    public function subscribe(AmqpConsumer $consumer, callable $callback);
+
+    /**
+     * @param AmqpConsumer $consumer
+     *
+     * @return void
+     */
+    public function unsubscribe(AmqpConsumer $consumer);
+
+    /**
+     * @param float|int $timeout milliseconds, consumes endlessly if zero set
+     *
+     * @return void
+     */
+    public function consume($timeout = 0);
 }