src/EventListener/RequestListener.php
private function getIronMqQueueName(GetResponseEvent $event, array&$message) {
		if (array_key_exists('_qpush_queue', $message)) {
			return $message['_qpush_queue'];
		} else if (null !== ($subscriberUrl = $event->getRequest()->headers->get('iron-subscriber-message-url'))) {
			if (preg_match('#/queues/([a-z0-9_-]+)/messages/#i', $subscriberUrl, $matches)) {
				$queue = $matches[1];
				if (substr($queue, 0, 6) == 'qpush_') {
					$queue = substr($queue, 6);
				}

				return $queue;
			}
		}

		throw new \RuntimeException('Unable to get queue name');
	}
private function getIronMqQueueName(GetResponseEvent $event, array&$message) {
		if (array_key_exists('_qpush_queue', $message)) {
			return $message['_qpush_queue'];
		} else if (null !== ($subscriberUrl = $event->getRequest()->headers->get('iron-subscriber-message-url'))) {
			if (preg_match('#/queues/([a-z0-9_-]+)/messages/#i', $subscriberUrl, $matches)) {
				$queue = $matches[1];
				if (substr($queue, 0, 6) == 'qpush_') {
					$queue = substr($queue, 6);
				}

				return $queue;
			}
		}

		throw new \RuntimeException('Unable to get queue name');
	}
private function getIronMqQueueName ( GetResponseEvent $ event , array & $ message ) { if ( array_key_exists ( '_qpush_queue' , $ message ) ) { return $ message [ '_qpush_queue' ] ; } else if ( null !== ( $ subscriberUrl = $ event -> getRequest ( ) -> headers -> get ( 'iron-subscriber-message-url' ) ) ) { if ( preg_match ( '#/queues/([a-z0-9_-]+)/messages/#i' , $ subscriberUrl , $ matches ) ) { $ queue = $ matches [ 1 ] ; if ( substr ( $ queue , 0 , 6 ) == 'qpush_' ) { $ queue = substr ( $ queue , 6 ) ; } return $ queue ; } } throw new \ RuntimeException ( 'Unable to get queue name' ) ; }
Get the name of the IronMq queue.

@param GetResponseEvent $event
@param array $message

@return string
Get the name of the IronMq queue .