@Component(value="cuba_SchedulingCoordinator") public class DbBasedCoordinator extends java.lang.Object implements Coordinator
Coordinator
interface, performing synchronization of singleton schedulers on the main
database.
This implementation should not be used if the database is overloaded.
Modifier and Type | Class and Description |
---|---|
protected static class |
DbBasedCoordinator.ContextImpl |
Coordinator.Context
Modifier and Type | Field and Description |
---|---|
protected Persistence |
persistence |
NAME
Constructor and Description |
---|
DbBasedCoordinator() |
Modifier and Type | Method and Description |
---|---|
Coordinator.Context |
begin() |
void |
end(Coordinator.Context context) |
long |
getLastFinished(ScheduledTask task) |
protected java.util.List<ScheduledTask> |
getTasks() |
boolean |
isLastExecutionFinished(ScheduledTask task,
long now) |
@Inject protected Persistence persistence
public Coordinator.Context begin()
begin
in interface Coordinator
public void end(Coordinator.Context context)
end
in interface Coordinator
public boolean isLastExecutionFinished(ScheduledTask task, long now)
isLastExecutionFinished
in interface Coordinator
public long getLastFinished(ScheduledTask task)
getLastFinished
in interface Coordinator
protected java.util.List<ScheduledTask> getTasks()