}
}
- protected void cancelImpl(DbSession dbSession, CeQueueDto q) {
+ private void cancelImpl(DbSession dbSession, CeQueueDto q) {
CeActivityDto activityDto = new CeActivityDto(q);
activityDto.setStatus(CeActivityDto.Status.CANCELED);
remove(dbSession, q, activityDto);
import org.sonar.ce.queue.CeQueue;
import org.sonar.ce.queue.CeTask;
import org.sonar.ce.queue.CeTaskResult;
-import org.sonar.db.DbSession;
import org.sonar.db.ce.CeActivityDto.Status;
-import org.sonar.db.ce.CeQueueDto;
/**
* Queue of pending Compute Engine tasks. Both producer and consumer actions
*/
void remove(CeTask task, Status status, @Nullable CeTaskResult taskResult, @Nullable Throwable error);
- void cancel(DbSession dbSession, CeQueueDto ceQueueDto);
-
void pausePeek();
void resumePeek();