|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.hibernate.search.backend.impl.jms.JmsBackendQueueProcessor
public abstract class JmsBackendQueueProcessor
Field Summary | |
---|---|
static String |
JMS_CONNECTION_FACTORY
|
static String |
JMS_CONNECTION_LOGIN
|
static String |
JMS_CONNECTION_PASSWORD
|
static String |
JMS_QUEUE
|
protected static String |
JNDI_PREFIX
|
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()
|
String |
getIndexName()
|
QueueConnection |
getJMSConnection()
|
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. |
protected abstract QueueConnection |
initializeJMSConnection(QueueConnectionFactory factory,
Properties props)
Initialises the JMS QueueConnection to be used for sending Lucene work operations to the master node. |
protected abstract Queue |
initializeJMSQueue(QueueConnectionFactory factory,
Properties props)
Initialises the JMS queue to be used for sending Lucene work operations to the master node. |
protected abstract QueueConnectionFactory |
initializeJMSQueueConnectionFactory(Properties props)
Initialises the JMS QueueConnectionFactory to be used for sending Lucene work operations to the master node. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final String JNDI_PREFIX
public static final String JMS_CONNECTION_FACTORY
public static final String JMS_QUEUE
public static final String JMS_CONNECTION_LOGIN
public static final String JMS_CONNECTION_PASSWORD
Constructor Detail |
---|
public JmsBackendQueueProcessor()
Method Detail |
---|
public void initialize(Properties props, WorkerBuildContext context, DirectoryBasedIndexManager indexManager)
BackendQueueProcessor
initialize
in interface BackendQueueProcessor
props
- all configuration propertiescontext
- context giving access to required meta dataindexManager
- the index it is related to.public Queue getJmsQueue()
public String getJmsQueueName()
public String getIndexName()
public SearchFactoryImplementor getSearchFactory()
public void applyWork(List<LuceneWork> workList, IndexingMonitor monitor)
BackendQueueProcessor
applyWork
in interface BackendQueueProcessor
workList
- list of Lucene work instance which need to be applied to the indexmonitor
- a IndexingMonitor
object.public void applyStreamWork(LuceneWork singleOperation, IndexingMonitor monitor)
BackendQueueProcessor
BackendQueueProcessor.applyWork(List, IndexingMonitor)
applyStreamWork
in interface BackendQueueProcessor
singleOperation
- single Lucene work instance to be applied to the indexmonitor
- a IndexingMonitor
object.public Lock getExclusiveWriteLock()
getExclusiveWriteLock
in interface BackendQueueProcessor
public void indexMappingChanged()
BackendQueueProcessor
indexMappingChanged
in interface BackendQueueProcessor
public QueueConnection getJMSConnection()
public void close()
BackendQueueProcessor
close
in interface BackendQueueProcessor
protected abstract QueueConnectionFactory initializeJMSQueueConnectionFactory(Properties props)
props
- a Properties
object.
javax.jms.QueueConnectionFactory
protected abstract Queue initializeJMSQueue(QueueConnectionFactory factory, Properties props)
initializeJMSQueueConnectionFactory(Properties)
factory
- a javax.jms.QueueConnectionFactory
object.props
- a Properties
object.
javax.jms.Queue
protected abstract QueueConnection initializeJMSConnection(QueueConnectionFactory factory, Properties props)
#initializeJMSQueue(Properties)
.
factory
- a javax.jms.QueueConnectionFactory
object.props
- a Properties
object.
javax.jms.QueueConnection
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |