org.hibernate.search.backend.impl.jms
Class JMSBackendQueueProcessor

java.lang.Object
  org.hibernate.search.backend.impl.jms.JMSBackendQueueProcessor

All Implemented Interfaces:

BackendQueueProcessor

public class JMSBackendQueueProcessor
extends Object
implements BackendQueueProcessor

Author:

Emmanuel Bernard, Hardy Ferentschik, Sanne Grinovero (C) 2011 Red Hat Inc.

Field Summary

static String	JMS_CONNECTION_FACTORY
static String	JMS_QUEUE

Constructor Summary

JMSBackendQueueProcessor()

Method Summary

void	applyStreamWork(LuceneWork singleOperation, IndexingMonitor monitor) Applies a single operation on the index, and different operations can be applied in parallel, even in parallel to a workList instance being processed by BackendQueueProcessor.applyWork(List, IndexingMonitor)
void	applyWork(List<LuceneWork> workList, IndexingMonitor monitor) Applies a list of operations to the index.
void	close() Used to shutdown and eventually release resources.
Lock	getExclusiveWriteLock()
QueueConnectionFactory	getJMSFactory()
Queue	getJmsQueue()
String	getJmsQueueName()
SearchFactoryImplementor	getSearchFactory()
void	indexMappingChanged() Used to notify the backend that the number or type of indexed entities being indexed in this backend changed.
void	initialize(Properties props, WorkerBuildContext context, DirectoryBasedIndexManager indexManager) Used at startup, called once as first method.
void	prepareJMSTools()

Methods inherited from class java.lang.Object

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

Field Detail

JMS_CONNECTION_FACTORY

public static final String JMS_CONNECTION_FACTORY

See Also:

Constant Field Values

JMS_QUEUE

public static final String JMS_QUEUE

See Also:

Constant Field Values

Constructor Detail

JMSBackendQueueProcessor

public JMSBackendQueueProcessor()

Method Detail

initialize

public void initialize(Properties props,
                       WorkerBuildContext context,
                       DirectoryBasedIndexManager indexManager)

Description copied from interface: BackendQueueProcessor

Used at startup, called once as first method.

Specified by:

initialize in interface BackendQueueProcessor

Parameters:

props - all configuration properties

context - context giving access to required meta data

indexManager - the index it is related to.

getJMSFactory

public QueueConnectionFactory getJMSFactory()

getJmsQueue

public Queue getJmsQueue()

getJmsQueueName

public String getJmsQueueName()

prepareJMSTools

public void prepareJMSTools()

getSearchFactory

public SearchFactoryImplementor getSearchFactory()

close

public void close()

Description copied from interface: BackendQueueProcessor

Used to shutdown and eventually release resources. No other method should be used after this one.

Specified by:

close in interface BackendQueueProcessor

applyWork

public void applyWork(List<LuceneWork> workList,
                      IndexingMonitor monitor)

Description copied from interface: BackendQueueProcessor

Applies a list of operations to the index. A single list might be processed by applying elements in parallel threads, but no work should be started on a new workList until the previous one was fully processed. Work could be applied asynchronously according to capabilities and configuration of implementor. A null parameter is not acceptable, implementations should throw an IllegalArgumentException.

Specified by:

applyWork in interface BackendQueueProcessor

Parameters:

workList - list of Lucene work instance which need to be applied to the index

applyStreamWork

public void applyStreamWork(LuceneWork singleOperation,
                            IndexingMonitor monitor)

Description copied from interface: BackendQueueProcessor

Applies a single operation on the index, and different operations can be applied in parallel, even in parallel to a workList instance being processed by BackendQueueProcessor.applyWork(List, IndexingMonitor)

Specified by:

applyStreamWork in interface BackendQueueProcessor

Parameters:

singleOperation - single Lucene work instance to be applied to the index

getExclusiveWriteLock

public Lock getExclusiveWriteLock()

Specified by:

getExclusiveWriteLock in interface BackendQueueProcessor

Returns:

a Lock instance which will block index modifications when acquired

indexMappingChanged

public void indexMappingChanged()

Description copied from interface: BackendQueueProcessor

Used to notify the backend that the number or type of indexed entities being indexed in this backend changed. This could trigger some needed reconfiguration.

Specified by:

indexMappingChanged in interface BackendQueueProcessor