public class StatefulEventDB
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TIME_ORDER |
Modifier | Constructor and Description |
---|---|
protected |
StatefulEventDB() |
Modifier and Type | Method and Description |
---|---|
void |
commit() |
void |
flush() |
java.util.List |
get(java.lang.String statii,
java.lang.String order,
boolean ascending) |
java.util.List<StatefulEvent> |
getAll() |
java.util.List<StatefulEvent> |
getAll(Status status) |
CacheEvent[] |
getByName(java.lang.String name) |
java.lang.String[] |
getCatalogs() |
java.lang.String[] |
getCatalogsFor(java.lang.String contributor) |
java.lang.String[] |
getContributors() |
StatefulEvent |
getEvent(int dbid) |
java.util.List<StatefulEvent> |
getEventInTimeRange(MicroSecondTimeRange range) |
java.util.List<StatefulEvent> |
getEventInTimeRange(MicroSecondTimeRange range,
Status status) |
java.util.List<StatefulEvent> |
getEventInTimeRangeRegardlessOfStatus(MicroSecondTimeRange range) |
StatefulEvent[] |
getEventsByTimeAndDepthRanges(MicroSecondDate minTime,
MicroSecondDate maxTime,
double minDepth,
double maxDepth) |
StatefulEvent |
getIdenticalEvent(CacheEvent e) |
StatefulEvent |
getLastEvent() |
StatefulEvent |
getNext(Standing standing)
next successful event to process.
|
int |
getNumEventsOfStatus(Standing standing) |
int |
getNumWaiting() |
org.hibernate.Session |
getSession() |
static StatefulEventDB |
getSingleton() |
long |
put(StatefulEvent event) |
java.util.List<StatefulEvent> |
query(EventFinderQuery q) |
void |
restartCompletedEvents() |
void |
rollback() |
public static final java.lang.String TIME_ORDER
public long put(StatefulEvent event)
public java.util.List<StatefulEvent> getAll()
public java.util.List<StatefulEvent> getAll(Status status)
public int getNumEventsOfStatus(Standing standing)
public StatefulEvent getEvent(int dbid) throws NotFound
NotFound
public java.util.List<StatefulEvent> getEventInTimeRange(MicroSecondTimeRange range)
public java.util.List<StatefulEvent> getEventInTimeRange(MicroSecondTimeRange range, Status status)
public java.util.List<StatefulEvent> getEventInTimeRangeRegardlessOfStatus(MicroSecondTimeRange range)
public java.util.List<StatefulEvent> query(EventFinderQuery q)
public StatefulEvent getLastEvent() throws NotFound
NotFound
public StatefulEvent[] getEventsByTimeAndDepthRanges(MicroSecondDate minTime, MicroSecondDate maxTime, double minDepth, double maxDepth)
public int getNumWaiting()
public StatefulEvent getNext(Standing standing)
public StatefulEvent getIdenticalEvent(CacheEvent e)
public java.util.List get(java.lang.String statii, java.lang.String order, boolean ascending)
public void flush()
public void commit()
public void rollback()
public org.hibernate.Session getSession()
public void restartCompletedEvents()
public static StatefulEventDB getSingleton()
public CacheEvent[] getByName(java.lang.String name)
public java.lang.String[] getCatalogs()
public java.lang.String[] getContributors()
public java.lang.String[] getCatalogsFor(java.lang.String contributor)