org.hibernate.search.batchindexing.impl
Class IdentifierConsumerEntityProducer

java.lang.Object
  org.hibernate.search.batchindexing.impl.IdentifierConsumerEntityProducer

All Implemented Interfaces:

SessionAwareRunnable

public class IdentifierConsumerEntityProducer
extends Object
implements SessionAwareRunnable

This Runnable is consuming entity identifiers and producing loaded detached entities for the next queue. It will finish when the queue it is consuming from will signal there are no more identifiers.

Author:

Sanne Grinovero

Constructor Summary

IdentifierConsumerEntityProducer(ProducerConsumerQueue<List<Serializable>> fromIdentifierListToEntities, ProducerConsumerQueue<List<?>> fromEntityToAddWork, MassIndexerProgressMonitor monitor, SessionFactory sessionFactory, CacheMode cacheMode, Class<?> type, String idName, ErrorHandler errorHandler)

Method Summary

void	run(Session upperSession)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdentifierConsumerEntityProducer

public IdentifierConsumerEntityProducer(ProducerConsumerQueue<List<Serializable>> fromIdentifierListToEntities,
                                        ProducerConsumerQueue<List<?>> fromEntityToAddWork,
                                        MassIndexerProgressMonitor monitor,
                                        SessionFactory sessionFactory,
                                        CacheMode cacheMode,
                                        Class<?> type,
                                        String idName,
                                        ErrorHandler errorHandler)

Method Detail

run

public void run(Session upperSession)

Specified by:

run in interface SessionAwareRunnable