nnx-framework / doctrine

     * @return ObjectManager

     * @throws \Nnx\Doctrine\ManagerRegistry\Exception\ObjectManagerNotFoundException

     */

    protected function getObjectManagerByName($name)

    {

        if (array_key_exists($name, $this->objectManagerByName)) {

            return $this->objectManagerByName[$name];

        }

        $event = clone $this->getManagerRegistryResourceEventPrototype();

        $event->setName(ManagerRegistryResourceEvent::RESOLVE_OBJECT_MANAGER_EVENT);

        $event->setResourceName($name);

        $event->setTarget($this);

        $resultsEvent = $this->getEventManager()->trigger($event, function ($objectManager) {

            return $objectManager instanceof ObjectManager;

        });

        $objectManager = $resultsEvent->last();

        if (!$objectManager instanceof ObjectManager) {

            $errMsg = sprintf('Object manager %s not found', $name);

            throw new Exception\ObjectManagerNotFoundException($errMsg);

        }

        $this->objectManagerByName[$name] = $objectManager;

        return $this->objectManagerByName[$name];

    }

    /**

     * @return mixed

     * @throws \Nnx\Doctrine\ManagerRegistry\Exception\ConnectionNotFoundException

     */

    protected function getConnectionByName($name)

    {

        if (array_key_exists($name, $this->connectionByName)) {

            return $this->connectionByName[$name];

        }

        $event = clone $this->getManagerRegistryResourceEventPrototype();

        $event->setName(ManagerRegistryResourceEvent::RESOLVE_CONNECTION_EVENT);

        $event->setResourceName($name);

        $event->setTarget($this);

        $resultsEvent = $this->getEventManager()->trigger($event, function ($connection) {

            return is_object($connection);

        });

        $connection = $resultsEvent->last();

        if (!is_object($connection)) {

            $errMsg = sprintf('Connection %s not found', $name);

            throw new Exception\ConnectionNotFoundException($errMsg);

        }

        $this->connectionByName[$name] = $connection;

        return $this->connectionByName[$name];

    }

    /**