src/Broker/Apollo/Mode/QueueBrowser.php
public function subscribe()
    {
        if (!$this->active) {
            $this->reachedEnd = false;
            $this->client->sendFrame(
                $this->getProtocol()->getSubscribeFrame(
                    $this->subscription->getDestination(),
                    $this->subscription->getSubscriptionId(),
                    $this->subscription->getAck(),
                    $this->subscription->getSelector(),
                    false
                )->addHeaders($this->getHeader())
            );
            $this->active = true;
        }
    }
public function subscribe()
    {
        if (!$this->active) {
            $this->reachedEnd = false;
            $this->client->sendFrame(
                $this->getProtocol()->getSubscribeFrame(
                    $this->subscription->getDestination(),
                    $this->subscription->getSubscriptionId(),
                    $this->subscription->getAck(),
                    $this->subscription->getSelector(),
                    false
                )->addHeaders($this->getHeader())
            );
            $this->active = true;
        }
    }
public function subscribe ( ) { if ( ! $ this -> active ) { $ this -> reachedEnd = false ; $ this -> client -> sendFrame ( $ this -> getProtocol ( ) -> getSubscribeFrame ( $ this -> subscription -> getDestination ( ) , $ this -> subscription -> getSubscriptionId ( ) , $ this -> subscription -> getAck ( ) , $ this -> subscription -> getSelector ( ) , false ) -> addHeaders ( $ this -> getHeader ( ) ) ) ; $ this -> active = true ; } }
Initialize subscription.

@return void
Initialize subscription .