Thanks for the suggestion. It's work, for the most part. I get it to reindex everything, but it throws an exception from the SeamPhaseListener after the method exists. I'm sure it has to do with the long running transaction.
import java.util.Date;
import javax.ejb.*;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import org.hibernate.*;
import org.hibernate.search.FullTextSession;
import org.hibernate.search.Search;
import org.jboss.annotation.ejb.TransactionTimeout;
import org.jboss.seam.annotations.*;
import org.jboss.seam.faces.FacesMessages;
import org.jboss.seam.log.Log;
// No need to carry state since the methods are self contained.
@Stateless
@Name("manage")
public class ManageBean implements ManageLocal {
// When Hibernate Search is present, seam will inject a FullTextEntityManager
@PersistenceContext
private EntityManager entityManager;
@Logger
private Log log;
@In
FacesMessages facesMessages;
// Need this to override the default timeout of 3 minutes for JBoss Transactions.
// You'll need the jboss-annotations-ejb3.jar in classpath to compile.
@TransactionTimeout(86400)
// Start new transaction for this method.
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public void reIndex() {
// Extract Session from EntityManager
Session lclSession = (Session)entityManager.getDelegate();
log.info("Starting ReIndexing Routine");
// Create a FullTextSession, so we can setup a scrollable cursor
// to keep the memory footprint down while we iterate through the
// list of objects.
FullTextSession ftSession = Search.createFullTextSession(lclSession);
ftSession.setFlushMode(FlushMode.MANUAL);
ftSession.setCacheMode(CacheMode.IGNORE);
Date start = new Date();
log.info("Getting Scrollable Cursor for Change Requests...");
//Scrollable results will avoid loading too many objects in memory
ScrollableResults results = ftSession.createCriteria( XXXX.class ).scroll( ScrollMode.FORWARD_ONLY );
log.info("Cursor retrieved... Start Indexing...");
int index = 0;
while( results.next() ) {
index++;
ftSession.index( results.get(0) ); //index each element
// The "25" matches the value established in the persistence.xml used to
// control batch sizes for Hibernate Search.
/**
<property name="hibernate.search.worker.batch_size" value="25"/>
*
*/
if (index % 25 == 0) {
// clear the session contents to keep memory footprint down.
ftSession.clear();
log.info("Records Indexed: " + index);
}
}
Date end = new Date();
long diff = end.getTime() - start.getTime();
log.info("ReIndexing Complete... # of records Indexed: " + index + " in " + diff + " ms.");
facesMessages.add("ReIndexed - Complete");
}
}
If anybody has a suggestion how to stop the exception thrown at the end, please post it here. Thanks.
Login
FAQ
Search
