public Startup createStartup(OMElement el) {
if (log.isDebugEnabled()) {
log.debug("Creating SimpleQuartz Task");
}
if (el.getQName().equals(TASK)) {
SimpleQuartz q = new SimpleQuartz();
String name = el.getAttributeValue(
new QName(XMLConfigConstants.NULL_NAMESPACE, "name"));
if (name != null) {
q.setName(name);
} else {
handleException("Name for a task is required, missing name in the task");
}
// set the task class
OMAttribute classAttr = el.getAttribute(new QName("class"));
if (classAttr != null && classAttr.getAttributeValue() != null) {
String classname = classAttr.getAttributeValue();
try {
Class.forName(classname).newInstance();
} catch (Exception e) {
handleException("Failed to load task class " + classname, e);
}
q.setJobClass(classname);
} else {
handleException("Syntax error in the Task : no task class specified");
}
// set pinned server list
OMAttribute pinnedServers = el.getAttribute(new QName(XMLConfigConstants.NULL_NAMESPACE, "pinnedServers"));
if (pinnedServers != null) {
String pinnedServersValue = pinnedServers.getAttributeValue();
if (pinnedServersValue == null) {
// default to all servers
} else {
StringTokenizer st = new StringTokenizer(pinnedServersValue, " ,");
List pinnedServersList = new ArrayList();
while (st.hasMoreTokens()) {
String token = st.nextToken();
if (token.length() != 0) {
pinnedServersList.add(token);
}
}
q.setPinnedServers(pinnedServersList);
}
}
// next sort out the property children
Iterator it = el.getChildrenWithName(PROPERTY);
while (it.hasNext()) {
OMElement prop = (OMElement) it.next();
if (PropertyHelper.isStaticProperty(prop)) {
q.addProperty(prop);
} else {
handleException("Tasks does not support dynamic properties");
}
}
// setting the trigger to the task
OMElement trigger = el.getFirstChildWithName(TRIGGER);
if (trigger != null) {
OMAttribute count = trigger.getAttribute(new QName("count"));
if (count != null) {
try {
q.setCount(Integer.parseInt(count.getAttributeValue()));
} catch (Exception e) {
handleException("Failed to parse trigger count as an integer", e);
}
}
OMAttribute once = trigger.getAttribute(new QName("once"));
if (once != null && Boolean.TRUE.toString().equals(once.getAttributeValue())) {
q.setCount(1);
q.setInterval(1);
}
OMAttribute repeatInterval = trigger.getAttribute(new QName("interval"));
if (repeatInterval == null && q.getCount() > 1) {
handleException("Trigger seems to be " +
"a simple trigger, but no interval specified");
} else if (repeatInterval != null && repeatInterval.getAttributeValue() != null) {
try {
long repeatIntervalInSeconds = Long.parseLong(repeatInterval.getAttributeValue());
long repeatIntervalInMillis = repeatIntervalInSeconds * 1000;
q.setInterval(repeatIntervalInMillis);
} catch (Exception e) {
handleException("Failed to parse trigger interval as a long value", e);
}
}
OMAttribute expr = trigger.getAttribute(new QName("cron"));
if (expr == null && q.getInterval() == 0) {
q.setCount(1);
q.setInterval(1);
} else if (expr != null && q.getInterval() > 0) {
handleException("Trigger syntax error : " +
"both cron and simple trigger attributes are present");
} else if (expr != null && expr.getAttributeValue() != null) {
q.setCron(expr.getAttributeValue());
}
} else {
q.setCount(1);
q.setInterval(1);
}
return q;
} else {
handleException("Syntax error in the task : wrong QName for the task");
return null;
}
}
|