rife2/rife2
rife2/rife2
2
0
Fork 0
mirror of https://github.com/ethauvin/rife2.git synced 2025-05-01 11:08:11 -07:00
Code Activity

Minor scheduler example cleanup.

Browse source
This commit is contained in:
Geert Bevin 2023-01-10 19:46:54 -05:00
parent 420b307336
commit a620b54d09
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
app/src/main/java/rife/HelloScheduler.java
View file

@ -11,7 +11,7 @@ import rife.scheduler.schedulermanagers.*;
public class HelloScheduler extends Site { public class HelloScheduler extends Site {
Datasource datasource = new Datasource("org.h2.Driver", "jdbc:h2:./embedded_dbs/h2/hello", "sa", "", 5); Datasource datasource = new Datasource("org.h2.Driver", "jdbc:h2:./embedded_dbs/h2/hello", "sa", "", 5);
DatabaseScheduling databaseScheduling = DatabaseSchedulingFactory.instance(datasource); DatabaseScheduling scheduling = DatabaseSchedulingFactory.instance(datasource);
public static class CounterExecutor extends Executor { public static class CounterExecutor extends Executor {
private int counter_ = 0; private int counter_ = 0;
@ -27,7 +27,7 @@ public class HelloScheduler extends Site {
} }
public void setup() { public void setup() {
final var scheduler = databaseScheduling.getScheduler(); final var scheduler = scheduling.getScheduler();
final var executor = new CounterExecutor(); final var executor = new CounterExecutor();
scheduler.addExecutor(executor); scheduler.addExecutor(executor);
@ -52,12 +52,12 @@ public class HelloScheduler extends Site {
printStatus(scheduler, c); printStatus(scheduler, c);
}); });
get("/install", c -> { get("/install", c -> {
databaseScheduling.install(); scheduling.install();
c.print("Installed"); c.print("Installed");
}); });
get("/remove", c -> { get("/remove", c -> {
scheduler.stop(); scheduler.stop();
databaseScheduling.remove(); scheduling.remove();
c.print("Removed"); c.print("Removed");
}); });
} }