Package ome.services.eventlogs

Class PersistentEventLogLoader

java.lang.Object

ome.services.eventlogs.EventLogLoader

ome.services.eventlogs.PersistentEventLogLoader

All Implemented Interfaces:

java.lang.Iterable<ome.model.meta.EventLog>, java.util.EventListener, java.util.Iterator<ome.model.meta.EventLog>, org.springframework.context.ApplicationListener

Direct Known Subclasses:

EventLogQueue, PersistentEventLogLoader, PersistentEventLogLoader

public abstract class PersistentEventLogLoader
extends EventLogLoader

EventLogLoader implementation which keeps tracks of the last EventLog instance, and always provides the next unindexed instance. Resetting that saved value would restart indexing.

Since:

3.0-Beta3

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	key	Key used to look configuration value; 'name'
protected ome.util.SqlAction	sql
protected ome.api.ITypes	types

Fields inherited from class ome.services.eventlogs.EventLogLoader

batchSize, DEFAULT_BATCH_SIZE, excludes, log, query, queryService

Constructor Summary

Constructors

Constructor	Description
PersistentEventLogLoader()

Method Summary

Modifier and Type	Method	Description
void	deleteCurrentId()
long	getCurrentId()	Get current EventLog id.
java.lang.String	getKey()
abstract void	initialize()	Called when the configuration database does not contain a valid current_id.
long	more()	Should return an estimate of how many more EventLog instances are available for processing.
protected ome.model.meta.EventLog	query()
void	setCurrentId(long id)
void	setKey(java.lang.String key)
void	setSqlAction(ome.util.SqlAction sql)
void	setTypes(ome.api.ITypes types)

Methods inherited from class ome.services.eventlogs.EventLogLoader

addEventLog, getBatchSize, hasNext, isStopSet, iterator, lastEventLog, next, nextEventLog, onApplicationEvent, remove, rollback, setBatchSize, setExcludes, setQueryService, setStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

key

protected java.lang.String key

Key used to look configuration value; 'name'

types

protected ome.api.ITypes types

sql

protected ome.util.SqlAction sql

Constructor Detail

PersistentEventLogLoader

public PersistentEventLogLoader()

Method Detail

setKey

public void setKey(java.lang.String key)

getKey

public java.lang.String getKey()

setTypes

public void setTypes(ome.api.ITypes types)

setSqlAction

public void setSqlAction(ome.util.SqlAction sql)

query

protected ome.model.meta.EventLog query()

Specified by:

query in class EventLogLoader

initialize

public abstract void initialize()

Called when the configuration database does not contain a valid current_id.

getCurrentId

public long getCurrentId()

Get current EventLog id. If the lookup throws an exception, either the configuration has been deleted or renamed, in which we need to reinitialize, or the table is missing and something is wrong.

setCurrentId

public void setCurrentId(long id)

deleteCurrentId

public void deleteCurrentId()

more

public long more()

Description copied from class: EventLogLoader

Should return an estimate of how many more EventLog instances are available for processing. Some implementations may attempt to take extra measures if the number is too large. Use 1 for a constant rather than Long.MAX_VALUE. Use 0 to stop execution.

Specified by:

more in class EventLogLoader