public class AMQJmsSearchController extends AbstractJMSHibernateSearchController
{
    private static final Logger logger = LoggerFactory.getLogger(AMQJmsSearchController.class);
    private SessionFactory sessionFactory;
    private volatile Session session;


    public SessionFactory getSessionFactory() {
        return sessionFactory;
    }

    @Required
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    @Override
    protected void afterMessage() {
        Session tempSession = session;
        session = null;
        if ( tempSession != null && tempSession.isOpen()) {
            tempSession.close();
        }
    }

    @Override
    protected SearchIntegrator getSearchIntegrator() {
        // http://stackoverflow.com/questions/28206502/access-directory-in-hibernate-search-5/28232872#28232872
        // https://forum.hibernate.org/viewtopic.php?f=9&t=1039407&start=15
        session = sessionFactory.openSession();
        final FullTextSession fullTextSession = Search.getFullTextSession(session);
        SearchIntegrator searchIntegrator = fullTextSession.getSearchFactory().unwrap(SearchIntegrator.class);

        return searchIntegrator;
    }
}

	public void onMessage(Message message) {
		if ( !( message instanceof ObjectMessage ) ) {
			log.incorrectMessageType( message.getClass() );
			return;
		}
		final ObjectMessage objectMessage = (ObjectMessage) message;
		final String indexName;
		final List<LuceneWork> queue;
		final IndexManager indexManager;
		SearchIntegrator integrator = getSearchIntegrator();
		try {
			indexName = extractIndexName( objectMessage );
			if ( log.isDebugEnabled() ) {
				logMessageDetails( objectMessage, indexName );
			}
			indexManager = integrator.getIndexManager( indexName );
			if ( indexManager == null ) {
				log.messageReceivedForUndefinedIndex( indexName );
				return;
			}

			queue = getSearchIntegrator().getWorkSerializer().toLuceneWorks( (byte[]) objectMessage.getObject() );
			indexManager.performOperations( queue, null );
		}
		catch (JMSException e) {
			log.unableToRetrieveObjectFromMessage( message.getClass(), e );
			return;
		}
		catch (ClassCastException e) {
			log.illegalObjectRetrievedFromMessage( e );
			return;
		}
		finally {
			afterMessage();
		}
	}