Package org.openiam.common.beans.sync

Class SynchronisationHelper

java.lang.Object

org.openiam.common.beans.sync.SynchronisationHelper

@Component
public class SynchronisationHelper
extends Object

Constructor Summary

Constructors

Constructor	Description
SynchronisationHelper()

Method Summary

Modifier and Type	Method	Description
void	createFileWithHeader(String header, String syncName, String rootAuditLogId)
void	generateAndWriteContentToReport(String entityName, String result, Exception e, String syncName, String rootAuditLogId)
String	getFileName(String rootAuditLogId, String syncName)
static <T> List<Part>	getParts(List<T> allObjects, int recordCountInBatch, Function<Part,List<T>> fieldAccessor)
boolean	isWriteToFile(String rootAuditLogId, String syncConfigName)
void	sweep()
void	writeToSyncReport(List<String> records, String fileName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronisationHelper

public SynchronisationHelper()

Method Detail

writeToSyncReport

public void writeToSyncReport(List<String> records,
                              String fileName)

Parameters:

records - - make sure to pass mutable list to this method

createFileWithHeader

public void createFileWithHeader(String header,
                                 String syncName,
                                 String rootAuditLogId)

getFileName

public String getFileName(String rootAuditLogId,
                          String syncName)

isWriteToFile

public boolean isWriteToFile(String rootAuditLogId,
                             String syncConfigName)

generateAndWriteContentToReport

public void generateAndWriteContentToReport(String entityName,
                                            String result,
                                            Exception e,
                                            String syncName,
                                            String rootAuditLogId)

sweep

@Scheduled(fixedDelay=10000L,
           initialDelay=100L)
public void sweep()

getParts

public static <T> List<Part> getParts(List<T> allObjects,
                                      int recordCountInBatch,
                                      Function<Part,List<T>> fieldAccessor)