Basic Usage¶
Prerequisites¶
Okra requires Java 8+ and Mongo Java Driver
Usage¶
- Add Okra to your project as you can see in the Installation page.
- Create a class that will store your specific job attributes
public class CheckJob extends DefaultOkraItem {
private String someAttribute;
//getters and setters
}
- Setup Okra with a MongoDB Driver
public OkraSync<CheckJob> setupOkra(MongoClient mongo): {
OkraSync<CheckJob> okra = new OkraSyncBuilder<CheckJob>()
.withMongo(mongo)
.withCollection("checkJob")
.withDatabase(mongoDatabaseName)
.withItemClass(CheckJob.class)
.withExpiration(2, TimeUnit.MINUTES)
.build();
okra.setup();
return okra;
}
- Schedule your job items
public void schedule(CheckJob item) {
okra.schedule(item);
}
- And start processing them…
public void process() {
CheckJob item = okra.peek();
if (item.isPresent()) {
// process
okra.reschedule(item)
// or okra.delete(item);
}
}
Enjoy Okra! :)