com.tsgrp.opencontent.alfresco.job

Class CleanUpStuckIndexingDocumentsJob

java.lang.Object

com.tsgrp.opencontent.alfresco.job.CleanUpStuckIndexingDocumentsJob

All Implemented Interfaces:

org.quartz.Job

public class CleanUpStuckIndexingDocumentsJob
extends java.lang.Object
implements org.quartz.Job

Constructor Summary

Constructors

Constructor and Description
CleanUpStuckIndexingDocumentsJob()

Method Summary

Modifier and Type	Method and Description
protected int	compareNodeTime(org.alfresco.service.cmr.repository.NodeService nodeService, org.alfresco.service.cmr.repository.NodeRef n, org.alfresco.service.namespace.QName timeProperty, java.util.Calendar compareTime) Return -1/0/+1 if n.timeProperty compareTime.
protected java.util.Calendar	computeThresholdTime(java.lang.Integer threshold) Get threshold value in seconds; default is 300 or 5 minutes but can be overridden by "threshold" request parameter.
void	execute(org.quartz.JobExecutionContext context)
protected void	executeTransactionWorkAsUser(org.alfresco.service.ServiceRegistry serviceRegistry, java.lang.String user, org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback<java.lang.String> transactionWork)
protected java.util.List<org.alfresco.service.cmr.repository.NodeRef>	findIndexingDocs(org.alfresco.service.ServiceRegistry serviceRegistry, java.lang.Integer maxDocsToUnlock, java.lang.String queryBase) Return any docs with indexStatus=Indexing, regardless of age.
protected void	processStuckDocs(org.alfresco.service.ServiceRegistry serviceRegistry, org.alfresco.service.cmr.repository.NodeService nodeService, java.lang.String queryBase, java.lang.Integer maxDocsToUnlock, java.util.Calendar thresholdTime) Attempt every which way to unlock the given doc; Working Copy Owner is special because we run the operations as them.
protected void	resetIndexStatus(org.alfresco.service.ServiceRegistry serviceRegistry, org.alfresco.service.cmr.repository.NodeService nodeService, org.alfresco.service.cmr.repository.NodeRef node, java.lang.String lockOwner) This method will reset the index status of a node
protected void	unlockDocument(org.alfresco.service.ServiceRegistry serviceRegistry, org.alfresco.service.cmr.repository.NodeService nodeService, org.alfresco.service.cmr.repository.NodeRef node, java.lang.String lockOwner) This method will unlock the node as well as reset the index status

Methods inherited from class java.lang.Object

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

Constructor Detail

CleanUpStuckIndexingDocumentsJob

public CleanUpStuckIndexingDocumentsJob()

Method Detail

execute

public void execute(org.quartz.JobExecutionContext context)

Specified by:

execute in interface org.quartz.Job

processStuckDocs

protected void processStuckDocs(org.alfresco.service.ServiceRegistry serviceRegistry,
                                org.alfresco.service.cmr.repository.NodeService nodeService,
                                java.lang.String queryBase,
                                java.lang.Integer maxDocsToUnlock,
                                java.util.Calendar thresholdTime)

Attempt every which way to unlock the given doc; Working Copy Owner is special because we run the operations as them. Let exceptions bubble up to calling method, since it catches and counts.

computeThresholdTime

protected java.util.Calendar computeThresholdTime(java.lang.Integer threshold)

Get threshold value in seconds; default is 300 or 5 minutes but can be overridden by "threshold" request parameter. Threshold is the latest a doc can be modified and still be included.

findIndexingDocs

protected java.util.List<org.alfresco.service.cmr.repository.NodeRef> findIndexingDocs(org.alfresco.service.ServiceRegistry serviceRegistry,
                                                                                       java.lang.Integer maxDocsToUnlock,
                                                                                       java.lang.String queryBase)

Return any docs with indexStatus=Indexing, regardless of age.

compareNodeTime

protected int compareNodeTime(org.alfresco.service.cmr.repository.NodeService nodeService,
                              org.alfresco.service.cmr.repository.NodeRef n,
                              org.alfresco.service.namespace.QName timeProperty,
                              java.util.Calendar compareTime)

Return -1/0/+1 if n.timeProperty compareTime.

unlockDocument

protected void unlockDocument(org.alfresco.service.ServiceRegistry serviceRegistry,
                              org.alfresco.service.cmr.repository.NodeService nodeService,
                              org.alfresco.service.cmr.repository.NodeRef node,
                              java.lang.String lockOwner)

This method will unlock the node as well as reset the index status

Parameters:

serviceRegistry -

nodeService -

node - - the node to unlock and reset

lockOwner - - the user who has the document locked

resetIndexStatus

protected void resetIndexStatus(org.alfresco.service.ServiceRegistry serviceRegistry,
                                org.alfresco.service.cmr.repository.NodeService nodeService,
                                org.alfresco.service.cmr.repository.NodeRef node,
                                java.lang.String lockOwner)

This method will reset the index status of a node

Parameters:

serviceRegistry -

nodeService -

node - - the node to unlock and reset

lockOwner - - the user who has the document locked

executeTransactionWorkAsUser

protected void executeTransactionWorkAsUser(org.alfresco.service.ServiceRegistry serviceRegistry,
                                            java.lang.String user,
                                            org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback<java.lang.String> transactionWork)