public class IdentityArchiveServiceImpl extends Object implements IdentityArchiveService, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean
IdentityArchiveService| Modifier and Type | Class and Description |
|---|---|
protected static class |
IdentityArchiveServiceImpl.CallableAdapter
Adapts a Callable to be Runnable
|
protected class |
IdentityArchiveServiceImpl.EntityArchiveWriter
store the person to the database, but do this an alternate thread to
prevent transaction issues since this service is non-transactional
|
protected static class |
IdentityArchiveServiceImpl.PreLogCallableWrapper<A>
decorator for a callable to log a message before it is executed
|
protected static class |
IdentityArchiveServiceImpl.WriteQueue
A class encapsulating a
ConcurrentLinkedQueue and an AtomicInteger to
provide fast offer(enqueue)/poll(dequeue) and size checking. |
| Modifier and Type | Field and Description |
|---|---|
protected DataObjectService |
dataObjectService |
protected static String |
EXEC_INTERVAL_SECS |
protected static int |
EXECUTION_INTERVAL_SECONDS_DEFAULT |
protected ConfigurationService |
kualiConfigurationService |
protected static String |
MAX_WRITE_QUEUE_SIZE |
protected static int |
MAX_WRITE_QUEUE_SIZE_DEFAULT |
protected Runnable |
maxQueueSizeExceededWriter |
protected Runnable |
scheduledWriter |
protected Runnable |
shutdownWriter |
protected org.springframework.transaction.PlatformTransactionManager |
transactionManager |
protected IdentityArchiveServiceImpl.WriteQueue |
writeQueue |
protected IdentityArchiveServiceImpl.EntityArchiveWriter |
writer |
| Constructor and Description |
|---|
IdentityArchiveServiceImpl() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet()
schedule the writer on the KSB scheduled pool.
|
void |
destroy()
flush the write queue immediately.
|
void |
flushToArchive()
Flushes
EntityDefault to the archive. |
EntityDefault |
getEntityDefaultFromArchive(String entityId)
Gets a
EntityDefault with an id from the archive. |
EntityDefault |
getEntityDefaultFromArchiveByEmployeeId(String employeeId)
Gets a
EntityDefault with an employeeId from the archive. |
EntityDefault |
getEntityDefaultFromArchiveByPrincipalId(String principalId)
Gets a
EntityDefault with an principalId from the archive. |
EntityDefault |
getEntityDefaultFromArchiveByPrincipalName(String principalName)
Gets a
EntityDefault with an principalName from the archive. |
protected int |
getExecutionIntervalSeconds() |
protected int |
getMaxWriteQueueSize() |
void |
saveEntityDefaultToArchive(EntityDefault entity)
Saves a
EntityDefault to the archive. |
void |
setDataObjectService(DataObjectService dataObjectService) |
void |
setKualiConfigurationService(ConfigurationService kualiConfigurationService) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager txMgr) |
protected DataObjectService dataObjectService
protected ConfigurationService kualiConfigurationService
protected org.springframework.transaction.PlatformTransactionManager transactionManager
protected static final String EXEC_INTERVAL_SECS
protected static final String MAX_WRITE_QUEUE_SIZE
protected static final int EXECUTION_INTERVAL_SECONDS_DEFAULT
protected static final int MAX_WRITE_QUEUE_SIZE_DEFAULT
protected final IdentityArchiveServiceImpl.WriteQueue writeQueue
protected final IdentityArchiveServiceImpl.EntityArchiveWriter writer
protected final Runnable maxQueueSizeExceededWriter
protected final Runnable scheduledWriter
protected final Runnable shutdownWriter
public IdentityArchiveServiceImpl()
protected int getExecutionIntervalSeconds()
protected int getMaxWriteQueueSize()
public EntityDefault getEntityDefaultFromArchive(String entityId)
IdentityArchiveServiceEntityDefault with an id from the archive.
EntityDefault is a condensed version of Entity that contains
default values of its subclasses
This method will return null if the Entity does not exist.
getEntityDefaultFromArchive in interface IdentityArchiveServiceentityId - the unique id to retrieve the entity by. cannot be null.EntityDefault or nullpublic EntityDefault getEntityDefaultFromArchiveByPrincipalId(String principalId)
IdentityArchiveServiceEntityDefault with an principalId from the archive.
EntityDefault is a condensed version of Entity that contains
default values of its subclasses
This method will return null if the Entity does not exist.
getEntityDefaultFromArchiveByPrincipalId in interface IdentityArchiveServiceprincipalId - the unique principalId to retrieve the entity by. cannot be null.EntityDefault or nullpublic EntityDefault getEntityDefaultFromArchiveByPrincipalName(String principalName)
IdentityArchiveServiceEntityDefault with an principalName from the archive.
EntityDefault is a condensed version of Entity that contains
default values of its subclasses
This method will return null if the Entity does not exist.
getEntityDefaultFromArchiveByPrincipalName in interface IdentityArchiveServiceprincipalName - the unique principalName to retrieve the entity by. cannot be null.EntityDefault or nullpublic EntityDefault getEntityDefaultFromArchiveByEmployeeId(String employeeId)
IdentityArchiveServiceEntityDefault with an employeeId from the archive.
EntityDefault is a condensed version of Entity that contains
default values of its subclasses
This method will return null if the Entity does not exist.
getEntityDefaultFromArchiveByEmployeeId in interface IdentityArchiveServiceemployeeId - the unique employeeId to retrieve the entity by. cannot be null.EntityDefault or nullpublic void saveEntityDefaultToArchive(EntityDefault entity)
IdentityArchiveServiceEntityDefault to the archive.
EntityDefault is a condensed version of Entity that contains
default values of its subclasses
This method will return the saved EntityDefault object
saveEntityDefaultToArchive in interface IdentityArchiveServiceentity - the unique principalName to retrieve the entity by. cannot be null.public void flushToArchive()
IdentityArchiveServiceEntityDefault to the archive.
This method flushes the "saved" entities to the database
flushToArchive in interface IdentityArchiveServicepublic void setKualiConfigurationService(ConfigurationService kualiConfigurationService)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager txMgr)
public void afterPropertiesSet() throws Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanExceptionpublic void destroy() throws Exception
destroy in interface org.springframework.beans.factory.DisposableBeanExceptionpublic void setDataObjectService(DataObjectService dataObjectService)
dataObjectService - the dataObjectService to setCopyright © 2005–2016 The Kuali Foundation. All rights reserved.