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)
IdentityArchiveService
EntityDefault
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 IdentityArchiveService
entityId
- the unique id to retrieve the entity by. cannot be null.EntityDefault
or nullpublic EntityDefault getEntityDefaultFromArchiveByPrincipalId(String principalId)
IdentityArchiveService
EntityDefault
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 IdentityArchiveService
principalId
- the unique principalId to retrieve the entity by. cannot be null.EntityDefault
or nullpublic EntityDefault getEntityDefaultFromArchiveByPrincipalName(String principalName)
IdentityArchiveService
EntityDefault
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 IdentityArchiveService
principalName
- the unique principalName to retrieve the entity by. cannot be null.EntityDefault
or nullpublic EntityDefault getEntityDefaultFromArchiveByEmployeeId(String employeeId)
IdentityArchiveService
EntityDefault
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 IdentityArchiveService
employeeId
- the unique employeeId to retrieve the entity by. cannot be null.EntityDefault
or nullpublic void saveEntityDefaultToArchive(EntityDefault entity)
IdentityArchiveService
EntityDefault
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 IdentityArchiveService
entity
- the unique principalName to retrieve the entity by. cannot be null.public void flushToArchive()
IdentityArchiveService
EntityDefault
to the archive.
This method flushes the "saved" entities to the database
flushToArchive
in interface IdentityArchiveService
public void setKualiConfigurationService(ConfigurationService kualiConfigurationService)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager txMgr)
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
public void destroy() throws Exception
destroy
in interface org.springframework.beans.factory.DisposableBean
Exception
public void setDataObjectService(DataObjectService dataObjectService)
dataObjectService
- the dataObjectService to setCopyright © 2005–2016 The Kuali Foundation. All rights reserved.