Client.php
public function consume($queue, $prefetchCount = null, $prefetchSize = null, $consumerId = null): Observable
    {
        return $this->channel()
            ->do(function (Channel $channel) use ($prefetchCount, $prefetchSize) {
                $channel->qos($prefetchSize, $prefetchCount);
            })
            ->flatMap(
                function (Channel $channel) use ($queue, $consumerId) {
                    return $this->queue($queue, $channel)
                        ->consume($consumerId);
                }
            );
    }
public function consume($queue, $prefetchCount = null, $prefetchSize = null, $consumerId = null): Observable
    {
        return $this->channel()
            ->do(function (Channel $channel) use ($prefetchCount, $prefetchSize) {
                $channel->qos($prefetchSize, $prefetchCount);
            })
            ->flatMap(
                function (Channel $channel) use ($queue, $consumerId) {
                    return $this->queue($queue, $channel)
                        ->consume($consumerId);
                }
            );
    }
public function consume ( $ queue , $ prefetchCount = null , $ prefetchSize = null , $ consumerId = null ) : Observable { return $ this -> channel ( ) -> do ( function ( Channel $ channel ) use ( $ prefetchCount , $ prefetchSize ) { $ channel -> qos ( $ prefetchSize , $ prefetchCount ) ; } ) -> flatMap ( function ( Channel $ channel ) use ( $ queue , $ consumerId ) { return $ this -> queue ( $ queue , $ channel ) -> consume ( $ consumerId ) ; } ) ; }
Consume given queue at.
Consume given queue at .