src/Broker/ActiveMq/ActiveMq.php
public function getSubscribeFrame(
        $destination,
        $subscriptionId = null,
        $ack = 'auto',
        $selector = null,
        $durable = false
    ) {
        $frame = parent::getSubscribeFrame($destination, $subscriptionId, $ack, $selector);
        $frame['activemq.prefetchSize'] = $this->prefetchSize;
        if ($durable) {
            $frame['activemq.subscriptionName'] = $this->getClientId();
        }
        return $frame;
    }
public function getSubscribeFrame(
        $destination,
        $subscriptionId = null,
        $ack = 'auto',
        $selector = null,
        $durable = false
    ) {
        $frame = parent::getSubscribeFrame($destination, $subscriptionId, $ack, $selector);
        $frame['activemq.prefetchSize'] = $this->prefetchSize;
        if ($durable) {
            $frame['activemq.subscriptionName'] = $this->getClientId();
        }
        return $frame;
    }
public function getSubscribeFrame ( $ destination , $ subscriptionId = null , $ ack = 'auto' , $ selector = null , $ durable = false ) { $ frame = parent :: getSubscribeFrame ( $ destination , $ subscriptionId , $ ack , $ selector ) ; $ frame [ 'activemq.prefetchSize' ] = $ this -> prefetchSize ; if ( $ durable ) { $ frame [ 'activemq.subscriptionName' ] = $ this -> getClientId ( ) ; } return $ frame ; }
ActiveMq subscribe frame.

@param string $destination
@param string $subscriptionId
@param string $ack
@param string $selector
@param boolean|false $durable durable subscription
@return Frame
ActiveMq subscribe frame .