Package io.jans.link.timer

Class JansLinkTimer

java.lang.Object

io.jans.link.service.BaseJansLinkTimer

io.jans.link.timer.JansLinkTimer

@ApplicationScoped
public class JansLinkTimer
extends BaseJansLinkTimer

Check periodically if source servers contains updates and trigger target server entry update if needed

Author:

Yuriy Movchan Date: 05.05.2011

Nested Class Summary

Nested classes/interfaces inherited from class io.jans.link.service.BaseJansLinkTimer

BaseJansLinkTimer.LdapServerConnection, BaseJansLinkTimer.TypedGluuSimplePerson

Field Summary

Fields

Modifier and Type	Field	Description
protected ApplicationFactory	applicationFactory

Constructor Summary

Constructors

Constructor	Description
JansLinkTimer()

Method Summary

Modifier and Type	Method	Description
ArrayList<JansInumMap>	applyChangesToInumMap(HashMap<String,JansInumMap> inumInumMap, HashMap<CacheCompoundKey,JansInumMap> addedPrimaryKeyAttrValueInumMap, List<String> removedGluuInumMaps)
HashMap<CacheCompoundKey,JansInumMap>	getAllInumServerEntries(HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap, HashMap<CacheCompoundKey,JansInumMap> addedPrimaryKeyAttrValueInumMap)
ConfigurationFactory	getConfigurationFactory()
HashMap<String,CacheCompoundKey>	getInumCacheCompoundKeyMap(HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap)
HashMap<String,JansInumMap>	getInumInumMap(List<JansInumMap> inumMaps)
HashMap<CacheCompoundKey,JansInumMap>	getPrimaryKeyAttrValueInumMap(List<JansInumMap> inumMaps)
HashMap<String,Integer>	getSourcePersonsHashCodesMap(BaseJansLinkTimer.LdapServerConnection inumDbServerConnection, Map<CacheCompoundKey,GluuSimplePerson> sourcePersonCacheCompoundKeyMap, HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap)
void	initTimer()
List<JansInumMap>	loadInumServerEntries(LinkConfiguration linkConfiguration, BaseJansLinkTimer.LdapServerConnection inumDbServerConnection)
BaseJansLinkTimer.LdapServerConnection	prepareLdapServerConnection(LinkConfiguration linkConfiguration, io.jans.model.ldap.GluuLdapConfiguration ldapConfiguration)
void	process(LinkEvent linkEvent)
void	processInt()
void	setConfigurationFactory(ConfigurationFactory configurationFactory)
List<String>	updateTargetEntriesViaCopy(LinkConfiguration linkConfiguration, Map<CacheCompoundKey,GluuSimplePerson> sourcePersonCacheCompoundKeyMap, HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap, Set<String> changedInums)

Methods inherited from class io.jans.link.service.BaseJansLinkTimer

addGluuInumMap, closeLdapServerConnection, getBaseDNs, getChangedInums, getCompoundKeyAttributes, getCompoundKeyAttributesWithoutValues, getCompoundKeyObjectClasses, getInumCachePath, getIsActive, getLdapEntryManager, getRemovedPersons, getSourceAttributes, getTargetServerAttributesMapping, getUpdateMethod, loadSourceServerEntries, loadSourceServerEntriesWithoutLimits, loadTargetServerEntries, processTargetPersons, setIsActive, setLdapEntryManager, toLdapProperties, updateTargetEntriesViaVDS, updateTargetEntryViaCopy, validateTargetServerSchema

Methods inherited from class java.lang.Object

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

Field Details

applicationFactory

@Inject
protected ApplicationFactory applicationFactory

Constructor Details

JansLinkTimer

public JansLinkTimer()

Method Details

initTimer

public void initTimer()

process

@Asynchronous
public void process(@Observes
 LinkEvent linkEvent)

processInt

public void processInt()

prepareLdapServerConnection

public BaseJansLinkTimer.LdapServerConnection prepareLdapServerConnection(LinkConfiguration linkConfiguration,
 io.jans.model.ldap.GluuLdapConfiguration ldapConfiguration)

getConfigurationFactory

public ConfigurationFactory getConfigurationFactory()

setConfigurationFactory

public void setConfigurationFactory(ConfigurationFactory configurationFactory)

applyChangesToInumMap

public ArrayList<JansInumMap> applyChangesToInumMap(HashMap<String,JansInumMap> inumInumMap,
 HashMap<CacheCompoundKey,JansInumMap> addedPrimaryKeyAttrValueInumMap,
 List<String> removedGluuInumMaps)

updateTargetEntriesViaCopy

public List<String> updateTargetEntriesViaCopy(LinkConfiguration linkConfiguration,
 Map<CacheCompoundKey,GluuSimplePerson> sourcePersonCacheCompoundKeyMap,
 HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap,
 Set<String> changedInums)

getInumCacheCompoundKeyMap

public HashMap<String,CacheCompoundKey> getInumCacheCompoundKeyMap(HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap)

loadInumServerEntries

public List<JansInumMap> loadInumServerEntries(LinkConfiguration linkConfiguration,
 BaseJansLinkTimer.LdapServerConnection inumDbServerConnection)

getAllInumServerEntries

public HashMap<CacheCompoundKey,JansInumMap> getAllInumServerEntries(HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap,
 HashMap<CacheCompoundKey,JansInumMap> addedPrimaryKeyAttrValueInumMap)

getSourcePersonsHashCodesMap

public HashMap<String,Integer> getSourcePersonsHashCodesMap(BaseJansLinkTimer.LdapServerConnection inumDbServerConnection,
 Map<CacheCompoundKey,GluuSimplePerson> sourcePersonCacheCompoundKeyMap,
 HashMap<CacheCompoundKey,JansInumMap> primaryKeyAttrValueInumMap)

getPrimaryKeyAttrValueInumMap

public HashMap<CacheCompoundKey,JansInumMap> getPrimaryKeyAttrValueInumMap(List<JansInumMap> inumMaps)

getInumInumMap

public HashMap<String,JansInumMap> getInumInumMap(List<JansInumMap> inumMaps)