1 package com.atlassian.core.task;
2
3 import com.atlassian.core.task.DefaultTaskManager;
4 import com.atlassian.core.task.DefaultTaskQueue;
5 import com.atlassian.core.task.Task;
6 import com.atlassian.core.task.TaskQueue;
7 import junit.framework.TestCase;
8
9
10
11
12
13
14
15
16 public class TaskManagerTestCase extends TestCase
17 {
18 public void testTaskManager()
19 {
20 final boolean[] task1executed = new boolean[1];
21 final boolean[] task2executed = new boolean[1];
22
23 TaskQueue queue = new DefaultTaskQueue();
24 DefaultTaskManager manager = new DefaultTaskManager(queue);
25 Task task1 = new Task(){
26 public void execute() throws Exception { task1executed[0] = true; }
27 };
28
29 Task task2 = new Task(){
30 public void execute() throws Exception { task2executed[0] = true; }
31 };
32
33 manager.addTask(task1);
34 manager.addTask(task2);
35
36 assertNotNull(manager.getTaskQueue());
37 assertEquals(2, manager.getTaskQueue().size());
38 manager.flush();
39 assertNull(manager.getTaskQueue().getFlushStarted());
40 assertTrue(task1executed[0]);
41 assertTrue(task2executed[0]);
42
43 }
44 }