public interface RunDBSupport
Modifier and Type | Method and Description |
---|---|
void |
checkForFinishNow()
Scan each run to see if it has finished yet and issue registered
notifications if it has.
|
void |
cleanNow()
Remove currently-expired runs from this database.
|
int |
countRuns()
How many runs are stored in the database.
|
void |
flushToDisk(RemoteRunDelegate run)
Ensure that a run gets persisted in the database.
|
FactoryBean |
getFactory() |
List<String> |
listRunNames()
Get a list of all the run names.
|
RemoteRunDelegate |
pickArbitraryRun()
Select an arbitrary representative run.
|
void |
setNotificationEngine(NotificationEngine notificationEngine) |
void |
setNotifier(CompletionNotifier notifier) |
void checkForFinishNow()
void cleanNow()
int countRuns()
void flushToDisk(@Nonnull RemoteRunDelegate run)
run
- The run to persist.@Nullable RemoteRunDelegate pickArbitraryRun() throws Exception
Exception
- If anything goes wrong.@Nonnull List<String> listRunNames()
void setNotificationEngine(NotificationEngine notificationEngine)
notificationEngine
- A reference to the notification fabric bean.void setNotifier(CompletionNotifier notifier)
notifier
- A reference to the bean that creates messages about workflow
run termination.FactoryBean getFactory()
Copyright © 2015–2018 The Apache Software Foundation. All rights reserved.