public class Jobs
extends java.lang.Object
| Constructor and Description |
|---|
Jobs(java.sql.Connection c,
com.fasterxml.jackson.databind.ObjectMapper m) |
| Modifier and Type | Method and Description |
|---|---|
void |
collect(int leeway) |
void |
doRetry(java.util.List<java.lang.Integer> ids) |
java.util.List<Job> |
getAllRunning() |
java.util.Optional<Job> |
getJob(int id) |
void |
updateJob(Job j) |
public Jobs(java.sql.Connection c,
com.fasterxml.jackson.databind.ObjectMapper m)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<Job> getAllRunning() throws java.sql.SQLException
java.sql.SQLExceptionpublic void doRetry(java.util.List<java.lang.Integer> ids)
public java.util.Optional<Job> getJob(int id) throws java.sql.SQLException, java.io.IOException
java.sql.SQLExceptionjava.io.IOExceptionpublic void updateJob(Job j) throws java.sql.SQLException, com.fasterxml.jackson.core.JsonProcessingException
java.sql.SQLExceptioncom.fasterxml.jackson.core.JsonProcessingExceptionpublic void collect(int leeway)
throws java.sql.SQLException
java.sql.SQLException