public class TaskMongoDao extends EPJLifeCycle implements TaskDao
Modifier and Type | Field and Description |
---|---|
private static java.lang.String |
COLLECTION_NAME |
private static org.slf4j.Logger |
log |
private com.mongodb.Mongo |
mongo |
private org.springframework.data.mongodb.core.MongoOperations |
mongoOps |
private static org.springframework.data.mongodb.core.query.Update |
UPDATE_STATUS_TO_RECOVERING |
private static org.springframework.data.mongodb.core.query.Query |
WHERE_STATUS_EQ_RECOVERING |
Constructor and Description |
---|
TaskMongoDao(org.springframework.data.mongodb.core.MongoOperations mongoOps,
com.mongodb.Mongo mongo) |
Modifier and Type | Method and Description |
---|---|
void |
delete(Task task) |
void |
deleteTasksCompletedBefore(org.joda.time.DateTime date)
Deletes tasks completed before a certain time, not just tasks with status
equal to Completed
|
protected void |
doStop() |
Task |
get(org.bson.types.ObjectId taskId) |
java.util.List<Task> |
getWithStatusesAndUpdateStatusTo(java.util.List<TaskStatus> statuses,
java.lang.String excludeTaskType) |
Task |
insert(Task task) |
void |
lifeCycleStopped(org.eclipse.jetty.util.component.LifeCycle event) |
void |
setTerminator(org.eclipse.jetty.util.component.LifeCycle terminatorDependency) |
void |
update(Task task) |
lifeCycleFailure, lifeCycleStarted, lifeCycleStarting, lifeCycleStopping
addLifeCycleListener, doStart, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
private static final org.slf4j.Logger log
private static final java.lang.String COLLECTION_NAME
private final org.springframework.data.mongodb.core.MongoOperations mongoOps
private final com.mongodb.Mongo mongo
private static final org.springframework.data.mongodb.core.query.Query WHERE_STATUS_EQ_RECOVERING
private static final org.springframework.data.mongodb.core.query.Update UPDATE_STATUS_TO_RECOVERING
@Inject public TaskMongoDao(org.springframework.data.mongodb.core.MongoOperations mongoOps, com.mongodb.Mongo mongo)
@Inject public void setTerminator(@Named(value="executor") org.eclipse.jetty.util.component.LifeCycle terminatorDependency)
protected void doStop() throws java.lang.Exception
doStop
in class org.eclipse.jetty.util.component.AbstractLifeCycle
java.lang.Exception
public void lifeCycleStopped(org.eclipse.jetty.util.component.LifeCycle event)
lifeCycleStopped
in interface org.eclipse.jetty.util.component.LifeCycle.Listener
lifeCycleStopped
in class EPJLifeCycle
public void deleteTasksCompletedBefore(org.joda.time.DateTime date)
deleteTasksCompletedBefore
in interface TaskDao
public java.util.List<Task> getWithStatusesAndUpdateStatusTo(java.util.List<TaskStatus> statuses, java.lang.String excludeTaskType)
getWithStatusesAndUpdateStatusTo
in interface TaskDao