Package org.openiam.sync.service.impl.srcadapter.adapters

Class LogAdapter

java.lang.Object

org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

org.openiam.sync.service.impl.srcadapter.adapters.LogAdapter

All Implemented Interfaces:

SourceAdapter

@Component
public class LogAdapter
extends AbstractSrcAdapter

Reads a Log file for use during the synchronization process

Field Summary

Fields inherited from class org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

auditLogHelper, mapper, propertyValueSweeper, provisionQueue, rabbitMQSender, scriptRunner, syncHelper, syncObjectProcessorFactory

Constructor Summary

Constructors

Constructor	Description
LogAdapter()

Method Summary

Modifier and Type	Method	Description
protected LastRecordMetric	getRowTime(LineObject rowObj, SynchConfig config)
protected LastRecordMetric	logProcessLineObject(LineObject rowObj, SynchConfig config, ValidationScript validationScript, List<TransformScript> transformScripts, SimpleDateFormat sdf)
SyncResponse	startSynch(SynchConfig config)
SyncResponse	startSynch(SynchConfig config, List<LineObject> objects)
Response	testConnection(SynchConfig config)
protected boolean	validatePartsGeneration(List<LineObject> lineObjects, SynchConfig config)

Methods inherited from class org.openiam.sync.service.impl.srcadapter.adapters.AbstractSrcAdapter

buildAuditLog, decryptPassword, getLastRecGeneralizedTime, getLastRecordMetric, getObjectString, hasError, incrementalSyncProcessing, mean, performTransformationScript, processLineObject, processPart, setMetric, setMetric, sum

Methods inherited from class java.lang.Object

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

Constructor Detail

LogAdapter

public LogAdapter()

Method Detail

testConnection

public Response testConnection(SynchConfig config)

validatePartsGeneration

protected boolean validatePartsGeneration(List<LineObject> lineObjects,
                                          SynchConfig config)

Specified by:

validatePartsGeneration in class AbstractSrcAdapter

getRowTime

protected LastRecordMetric getRowTime(LineObject rowObj,
                                      SynchConfig config)

Specified by:

getRowTime in class AbstractSrcAdapter

startSynch

public SyncResponse startSynch(SynchConfig config)
                        throws BasicDataServiceException

Specified by:

startSynch in interface SourceAdapter

Overrides:

startSynch in class AbstractSrcAdapter

Throws:

BasicDataServiceException

startSynch

public SyncResponse startSynch(SynchConfig config,
                               List<LineObject> objects)
                        throws BasicDataServiceException

Specified by:

startSynch in interface SourceAdapter

Overrides:

startSynch in class AbstractSrcAdapter

Throws:

BasicDataServiceException

logProcessLineObject

protected LastRecordMetric logProcessLineObject(LineObject rowObj,
                                                SynchConfig config,
                                                ValidationScript validationScript,
                                                List<TransformScript> transformScripts,
                                                SimpleDateFormat sdf)