ome.services.eventlogs

Class EventLogLoader

java.lang.Object

ome.services.eventlogs.EventLogLoader

All Implemented Interfaces:

Iterable<EventLog>, EventListener, Iterator<EventLog>, ApplicationListener

Direct Known Subclasses:

AllEntitiesPseudoLogLoader, AllEventsLogLoader, PersistentEventLogLoader

public abstract class EventLogLoader
extends Object
implements Iterator<EventLog>, Iterable<EventLog>, ApplicationListener

Data access object for the FullTextIndexer which provides an Iterator interface for EventLog instances to be properly indexed. Also supports the concept of batches. After batchSize queries,

Since:

3.0-Beta3

Author:

Josh Moore, josh at glencoesoftware.com

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchSize
static int	DEFAULT_BATCH_SIZE Currently 100.
protected List<String>	excludes Array of class types which will get excluded from indexing.
protected org.slf4j.Logger	log
protected String	query Query string to be kept in sync with excludes.
protected IQuery	queryService

Constructor Summary

Constructors

Constructor and Description
EventLogLoader()

Method Summary

Modifier and Type	Method and Description
boolean	addEventLog(Class<? extends IObject> cls, long id) Adds an EventLog for the given Class and id to the backlog.
int	getBatchSize()
boolean	hasNext() Tests for available objects.
boolean	isStopSet() Returns true if the stop flag has been set on this instance.
Iterator<EventLog>	iterator()
EventLog	lastEventLog()
abstract long	more() Should return an estimate of how many more EventLog instances are available for processing.
EventLog	next() Returns the current log instance which may be loaded by a call to hasNext() if necessary.
EventLog	nextEventLog(long id) Returns the EventLog with the next id after the given argument or null if none exists.
void	onApplicationEvent(ApplicationEvent arg0)
protected abstract EventLog	query()
void	remove()
void	rollback(EventLog el)
void	setBatchSize(int batchSize) Set the number of EventLog instances will be loaded in a single run.
void	setExcludes(String[] excludes) Spring injector
void	setQueryService(IQuery queryService) Spring injector
void	setStop(boolean stop) Called by controlling objects (a worker thread) in order to free up the thread.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

log

protected final org.slf4j.Logger log

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

Currently 100.

See Also:

Constant Field Values

batchSize

protected int batchSize

excludes

protected List<String> excludes

Array of class types which will get excluded from indexing.

query

protected String query

Query string to be kept in sync with excludes.

See Also:

initQueryString()

queryService

protected IQuery queryService

Constructor Detail

EventLogLoader

public EventLogLoader()

Method Detail

setBatchSize

public void setBatchSize(int batchSize)

Set the number of EventLog instances will be loaded in a single run. If not set, DEFAULT_BATCH_SIZE will be used.

Parameters:

batchSize -

getBatchSize

public int getBatchSize()

setExcludes

public void setExcludes(String[] excludes)

Spring injector

setQueryService

public void setQueryService(IQuery queryService)

Spring injector

hasNext

public boolean hasNext()

Tests for available objects. If count is -1, then this batch has ended (set in next()) and false will be returned, EventBacklog will be ready to be switched over to an "adding" state if empty, andcount is also reset so further calls can finish normally; otherwise query() is called to load a new eventLog. Otherwise, just tests that field for null.

Specified by:

hasNext in interface Iterator<EventLog>

next

public EventLog next()

Returns the current log instance which may be loaded by a call to hasNext() if necessary. If hasNext() returns false, a NoSuchElementException will be thrown.

Specified by:

next in interface Iterator<EventLog>

remove

public final void remove()

Specified by:

remove in interface Iterator<EventLog>

rollback

public void rollback(EventLog el)

query

protected abstract EventLog query()

iterator

public Iterator<EventLog> iterator()

Specified by:

iterator in interface Iterable<EventLog>

more

public abstract long more()

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.

nextEventLog

public final EventLog nextEventLog(long id)

Returns the EventLog with the next id after the given argument or null if none exists. This method will only return "true" EventLog instances, with a valid id.

lastEventLog

public final EventLog lastEventLog()

addEventLog

public boolean addEventLog(Class<? extends IObject> cls,
                           long id)

Adds an EventLog for the given Class and id to the backlog.

onApplicationEvent

public void onApplicationEvent(ApplicationEvent arg0)

Specified by:

onApplicationEvent in interface ApplicationListener

isStopSet

public boolean isStopSet()

Returns true if the stop flag has been set on this instance.

setStop

public void setStop(boolean stop)

Called by controlling objects (a worker thread) in order to free up the thread.