Transaction userTx = null;

        try {
            log.debug("deleting indexed documents");
            FullTextHibernateSessionProxy proxy = (FullTextHibernateSessionProxy) entityManager.getDelegate();
//            EntityManager em = entityManager;//(EntityManager) Component.getInstance("entityManager");
//            Session session = (Session) em.getDelegate();
            userTx = proxy.beginTransaction();
//            userTx.begin();

            // Delete all documents with "_hibernate_class" term of the selected entity
            DirectoryProvider dirProvider = proxy.getSearchFactory().getDirectoryProviders(entityClass)[0];
            IndexReader reader = IndexReader.open(dirProvider.getDirectory());

            // TODO: This is using an internal term of HSearch
            reader.deleteDocuments(new Term("_hibernate_class", entityClass.getName()));
            reader.close();

            // Optimize index
            log.debug("optimizing index (merging segments)");
            proxy.getSearchFactory().optimize(entityClass);

            userTx.commit();

            log.debug("indexing documents in batches of: " + batchSize);

            // Now re-index with HSearch
            proxy = (FullTextHibernateSessionProxy) entityManager.getDelegate();
            userTx = proxy.beginTransaction();
//            userTx.begin();

            // Use HQL instead of Criteria to eager fetch lazy properties
            ScrollableResults cursor = proxy
                    .createQuery("select o from " + entityClass.getName() + " o where status=:status")
                    .setParameter("status", Constants.Status.ACTIVE).scroll();
            cursor.last();
            int count = cursor.getRowNumber() + 1;  // rowNumber will be -1 if there is no row
            cursor.first(); // Reset to first result row
            int i = 0;
            while (true && count > 0) {
                i++;
                Object o = cursor.get(0);
                log.debug("indexing: " + i);
                proxy.index(o);
                if (i % batchSize == 0) proxy.clear(); // Clear persistence context for each batch

                if (cursor.isLast())
                    break;
                else
                    cursor.next();
            }
            cursor.close();
            userTx.commit();

            log.debug("indexing complete of entity class: " + entityClass);

        } catch (Exception ex) {
            try {
                if (userTx != null) userTx.rollback();
            } catch (Exception rbEx) {
                rbEx.printStackTrace();
            }
            throw new RuntimeException(ex);
        }