src/ExchangeLocator/ContainerLocator.php
protected function getConnection(AMQPAwareMessage $message)
    {
        /** @var \Boekkooi\Bundle\AMQP\LazyConnection $connection */
        $connection = $this->container->get(sprintf(
            BoekkooiAMQPExtension::SERVICE_VHOST_CONNECTION_ID,
            $message->getVHost()
        ));

        return $connection->instance();
    }
protected function getConnection(AMQPAwareMessage $message)
    {
        /** @var \Boekkooi\Bundle\AMQP\LazyConnection $connection */
        $connection = $this->container->get(sprintf(
            BoekkooiAMQPExtension::SERVICE_VHOST_CONNECTION_ID,
            $message->getVHost()
        ));

        return $connection->instance();
    }
Get the @see \AMQPConnection instance for a @see AMQPAwareMessage instance.

@param AMQPAwareMessage $message
@return \AMQPConnection