protected function emitConnectionError(\Exception $exception, ConnectionInterface $connection)
    {
        $this->emit(
            'connect.error',
            array(
                $exception->getMessage(),
                $connection,
                $this->getLogger()
            )
        );
    }