import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
\r
-public class ExecuteRunableAction implements IJobStatusAction {\r
+public class ExecuteRunnableAction implements IJobStatusAction {\r
@Override\r
public void processAction(IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
jobRuntime.setStatus(JobStatus.WAIT_EXECUTOR);\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
\r
-public class FinishRunableAction implements IJobStatusAction {\r
+public class FinishRunnableAction implements IJobStatusAction {\r
@Override\r
public void processAction(IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
// jobs.remove(job.getJobId());\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
\r
-public class MessageRunableAction implements IJobStatusAction {\r
+public class MessageRunnableAction implements IJobStatusAction {\r
\r
@Override\r
public void processAction(IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
\r
-public class SuspendRunableAction implements IJobStatusAction {\r
+public class SuspendRunnableAction implements IJobStatusAction {\r
\r
@Override\r
public void processAction(IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
+++ /dev/null
-package user.jobengine.server.actions;
-
-import org.jmock.Expectations;
-import org.junit.Test;
-
-import user.commons.JobStatus;
-
-public class CancelRunableActionTest extends ActionTest {
-
- @Test
- public void testProcessAction() throws Exception {
- // Fixture
- final IJobStatusAction sut = new CancelRunableAction();
- context.checking(new Expectations() {{
- one (jobRuntime).setStatus(JobStatus.CANCELED);
- one (jobRuntime).setDescription("Canceled by user");
- one (jobRuntime).reset();
- one (jobEngine).removeFromRunQueue(jobRuntime);
- }});
-
- // Exercise, Verify
- sut.processAction(jobEngine, jobRuntime);
- }
-}
--- /dev/null
+package user.jobengine.server.actions;
+
+import org.jmock.Expectations;
+import org.junit.Test;
+
+import user.commons.JobStatus;
+
+public class CancelRunnableActionTest extends ActionTest {
+
+ @Test
+ public void testProcessAction() throws Exception {
+ // Fixture
+ final IJobStatusAction sut = new CancelRunnableAction();
+ context.checking(new Expectations() {
+ {
+ one(jobRuntime).setStatus(JobStatus.CANCELED);
+ one(jobRuntime).setDescription("Canceled by user");
+ one(jobRuntime).reset();
+ one(jobEngine).removeFromRunQueue(jobRuntime);
+ }
+ });
+
+ // Exercise, Verify
+ sut.processAction(jobEngine, jobRuntime);
+ }
+}
import user.commons.JobStatus;
-public class ExecuteRunableActionTest extends ActionTest {
+public class ExecuteRunnableActionTest extends ActionTest {
@Test
public void testProcessAction() throws Exception {
// Fixture
- final IJobStatusAction sut = new ExecuteRunableAction();
+ final IJobStatusAction sut = new ExecuteRunnableAction();
context.checking(new Expectations() {{
one (jobRuntime).setStatus(JobStatus.WAIT_EXECUTOR);
one (jobRuntime).saveStack();
import user.commons.JobStatus;
-public class FinishRunableActionTest extends ActionTest {
+public class FinishRunnableActionTest extends ActionTest {
@Test
public void testProcessAction() throws Exception {
// Fixture
- IJobStatusAction sut = new FinishRunableAction();
+ IJobStatusAction sut = new FinishRunnableAction();
context.checking(new Expectations() {{
one (jobRuntime).setFinished(with(any(Timestamp.class)));
one (jobRuntime).setStatus(JobStatus.FINISHED);