Package org.openiam.recon.service.impl.processor

Class AbstractReconciliationProcessor<T extends ExtensibleObject,M extends ProvisionObject>

java.lang.Object

org.openiam.recon.service.impl.processor.AbstractReconciliationProcessor<T,M>

All Implemented Interfaces:

ReconciliationProcessor

Direct Known Subclasses:

ReconciliationGroupProcessor, ReconciliationUserProcessor

public abstract class AbstractReconciliationProcessor<T extends ExtensibleObject,M extends ProvisionObject>
extends Object
implements ReconciliationProcessor

Field Summary

Fields

Modifier and Type	Field	Description
protected AuditLogHelper	auditLogHelper
protected ReconciliationCommandFactory	commandFactory
protected HashMap<String,Object>	dataMap
protected ReconHelper	helper
protected ManagedSystemCache	managedSystemCache
protected CustomJacksonMapper	mapper
protected MatchRuleProcessorFactory	matchRuleProcessorFactory
protected Integer	PACKAGE_SIZE
protected PropertyValueCache	propertyValueSweeper
protected RabbitMQSender	rabbitMQSender
protected ReconciliationConfigRabbitMQService	reconciliationConfigRabbitMQService
protected ReconPartProcessingQueue	reconPartProcessingQueue
protected ScriptIntegration	scriptRunner

Constructor Summary

Constructors

Constructor	Description
AbstractReconciliationProcessor()

Method Summary

Modifier and Type	Method	Description
protected String	buildSearchQuery(ReconciliationConfig config)
protected SearchObjectsProvisioningRequest	buildSearchRequest(List<ExtensibleAttribute> requestedExtensibleAttributes, String parentIdmAuditLogId, String searchQuery, ReconciliationConfig config, String searchObjectType)
protected <T> List<T>	findEntities(Function<Integer,BaseListResponse<T>> findFunction)
protected List<ExtensibleAttribute>	getAttributesFromPolicyMap(Set<AttributeMap> attrMap, PolicyMapObjectTypeOptions object, PolicyMapObjectTypeOptions principal)
protected String	getObjectString(Object o)
protected Set<AttributeMap>	obtainPolicyMap(ManagedSysDto managedSysDto, String policyObjectType)
protected void	performPopulationScript(ReconciliationObjectCommand<M> command, Map<ReconciliationSituationEnum,AbstractPopulationScript> populationScripts, ReconciliationSituationEnum situation, String principal, String managedSysId, M newObject, Map<String,Attribute> attributeMap, AuditLogBuilder childAuditLog, LastRecordMetric metric)
protected boolean	processReconciliationStop(String reconConfigId)
protected void	setMetric(AuditLogBuilder logBuilder, SyncMetrics newMetric)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openiam.recon.service.intf.processor.ReconciliationProcessor

continueReconciliationWithPartOfIDMData, continueReconciliationWithPartOfTargetData, splitDataAndRunByParts, startReconciliation

Field Detail

dataMap

protected HashMap<String,Object> dataMap

PACKAGE_SIZE

@Value("${org.openiam.recon.search.batch.size:250}")
protected Integer PACKAGE_SIZE

managedSystemCache

@Autowired
protected ManagedSystemCache managedSystemCache

propertyValueSweeper

@Autowired
protected PropertyValueCache propertyValueSweeper

rabbitMQSender

@Autowired
protected RabbitMQSender rabbitMQSender

auditLogHelper

@Autowired
protected AuditLogHelper auditLogHelper

mapper

@Autowired
protected CustomJacksonMapper mapper

scriptRunner

@Autowired
protected ScriptIntegration scriptRunner

matchRuleProcessorFactory

@Autowired
protected MatchRuleProcessorFactory matchRuleProcessorFactory

commandFactory

@Autowired
protected ReconciliationCommandFactory commandFactory

reconciliationConfigRabbitMQService

@Autowired
protected ReconciliationConfigRabbitMQService reconciliationConfigRabbitMQService

helper

@Autowired
protected ReconHelper helper

reconPartProcessingQueue

@Autowired
protected ReconPartProcessingQueue reconPartProcessingQueue

Constructor Detail

AbstractReconciliationProcessor

public AbstractReconciliationProcessor()

Method Detail

getObjectString

protected String getObjectString(Object o)

setMetric

protected void setMetric(AuditLogBuilder logBuilder,
                         SyncMetrics newMetric)

getAttributesFromPolicyMap

protected List<ExtensibleAttribute> getAttributesFromPolicyMap(Set<AttributeMap> attrMap,
                                                               PolicyMapObjectTypeOptions object,
                                                               PolicyMapObjectTypeOptions principal)

obtainPolicyMap

protected Set<AttributeMap> obtainPolicyMap(ManagedSysDto managedSysDto,
                                            String policyObjectType)
                                     throws BasicDataServiceException

Throws:

BasicDataServiceException

buildSearchRequest

protected SearchObjectsProvisioningRequest buildSearchRequest(List<ExtensibleAttribute> requestedExtensibleAttributes,
                                                              String parentIdmAuditLogId,
                                                              String searchQuery,
                                                              ReconciliationConfig config,
                                                              String searchObjectType)

buildSearchQuery

protected String buildSearchQuery(ReconciliationConfig config)
                           throws BasicDataServiceException,
                                  ScriptEngineException

Throws:

BasicDataServiceException

ScriptEngineException

performPopulationScript

protected void performPopulationScript(ReconciliationObjectCommand<M> command,
                                       Map<ReconciliationSituationEnum,AbstractPopulationScript> populationScripts,
                                       ReconciliationSituationEnum situation,
                                       String principal,
                                       String managedSysId,
                                       M newObject,
                                       Map<String,Attribute> attributeMap,
                                       AuditLogBuilder childAuditLog,
                                       LastRecordMetric metric)

findEntities

protected <T> List<T> findEntities(Function<Integer,BaseListResponse<T>> findFunction)

processReconciliationStop

protected boolean processReconciliationStop(String reconConfigId)