| 1 package org.sapia.ubik.rmi.server; 2 3 import org.sapia.taskman.TaskManager; 4 import org.sapia.taskman.TaskOutput; 5 6 7 15 public class UbikTaskManager extends TaskManager { 16 public UbikTaskManager() { 17 super("ubik.rmi.TaskManager"); 18 super.setDaemon(true); 19 super.setRunInterval(2000); 20 super.start(); 21 } 22 23 26 protected TaskOutput newTaskOutput(String taskName) { 27 return new UbikTaskOutput(taskName); 28 } 29 30 33 static class UbikTaskOutput implements TaskOutput { 34 private String _taskName; 35 36 UbikTaskOutput(String taskName) { 37 _taskName = taskName; 38 } 39 40 43 public void close() { 44 } 45 46 49 public TaskOutput debug(Object msg) { 50 Log.debug(_taskName, msg); 51 52 return this; 53 } 54 55 58 public TaskOutput error(Object msg, Throwable err) { 59 Log.error(_taskName, msg, err); 60 61 return this; 62 } 63 64 67 public TaskOutput error(Object msg) { 68 Log.error(_taskName, msg); 69 70 return this; 71 } 72 73 76 public TaskOutput error(Throwable err) { 77 Log.error(_taskName, err); 78 79 return this; 80 } 81 82 85 public TaskOutput info(Object msg) { 86 Log.info(_taskName, msg); 87 88 return this; 89 } 90 91 94 public void setTaskName(String name) { 95 _taskName = name; 96 } 97 98 101 public TaskOutput warning(Object msg) { 102 Log.error(_taskName, msg); 103 104 return this; 105 } 106 } 107 } 108 | Popular Tags |