code: 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();
      }
docs: Get the @see \AMQPConnection instance for a @see AMQPAwareMessage instance.
  
  @param AMQPAwareMessage $message
  @return \AMQPConnection