SPR-4359 Initial commit of scheduling namespace support.

org.springframework.context/src/main/java/org/springframework/scheduling/config/ScheduledTasksBeanDefinitionParser.java

@@ -0,0 +1,101 @@
+/*
+ * Copyright 2002-2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.scheduling.config;
+
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+
+import org.springframework.beans.factory.config.RuntimeBeanReference;
+import org.springframework.beans.factory.support.BeanDefinitionBuilder;
+import org.springframework.beans.factory.support.ManagedMap;
+import org.springframework.beans.factory.xml.AbstractSingleBeanDefinitionParser;
+import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.util.StringUtils;
+
+/**
+ * Parser for the 'scheduled-tasks' element of the scheduling namespace.
+ * 
+ * @author Mark Fisher
+ * @since 3.0
+ */
+public class ScheduledTasksBeanDefinitionParser extends AbstractSingleBeanDefinitionParser {
+
+	@Override
+	protected boolean shouldGenerateId() {
+		return true;
+	}
+
+	@Override
+	protected String getBeanClassName(Element element) {
+		return "org.springframework.scheduling.config.ScheduledTaskRegistrar";
+	}
+
+	@Override
+	protected void doParse(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) {
+		ManagedMap<RuntimeBeanReference, String> cronTaskMap = new ManagedMap<RuntimeBeanReference, String>();
+		ManagedMap<RuntimeBeanReference, String> fixedDelayTaskMap = new ManagedMap<RuntimeBeanReference, String>();
+		ManagedMap<RuntimeBeanReference, String> fixedRateTaskMap = new ManagedMap<RuntimeBeanReference, String>();
+		NodeList childNodes = element.getChildNodes();
+		for (int i = 0; i < childNodes.getLength(); i++) {
+			Node child = childNodes.item(i);
+			if (!(child instanceof Element) || !child.getLocalName().equals("task")) {
+				continue;
+			}
+			Element taskElement = (Element) child;
+			String ref = taskElement.getAttribute("ref");
+			String method = taskElement.getAttribute("method");
+			RuntimeBeanReference runnableBeanRef = new RuntimeBeanReference(
+					this.createRunnableBean(ref, method, parserContext));
+			String cronAttribute = taskElement.getAttribute("cron");
+			if (StringUtils.hasText(cronAttribute)) {
+				cronTaskMap.put(runnableBeanRef, cronAttribute);
+			}
+			else {
+				String fixedDelayAttribute = taskElement.getAttribute("fixed-delay");
+				if (StringUtils.hasText(fixedDelayAttribute)) {
+					fixedDelayTaskMap.put(runnableBeanRef, fixedDelayAttribute);
+				}
+				else {
+					String fixedRateAttribute = taskElement.getAttribute("fixed-rate");
+					if (!StringUtils.hasText(fixedRateAttribute)) {
+						parserContext.getReaderContext().error(
+								"one of 'cron', 'fixed-delay', or 'fixed-rate' is required", taskElement);
+						return;
+					}
+					fixedRateTaskMap.put(runnableBeanRef, fixedRateAttribute);
+				}
+			}
+		}
+		String schedulerRef = element.getAttribute("scheduler");
+		if (StringUtils.hasText(schedulerRef)) {
+			builder.addPropertyReference("taskScheduler", schedulerRef);
+		}
+		builder.addPropertyValue("cronTasks", cronTaskMap);
+		builder.addPropertyValue("fixedDelayTasks", fixedDelayTaskMap);
+		builder.addPropertyValue("fixedRateTasks", fixedRateTaskMap);
+	}
+
+	private String createRunnableBean(String ref, String method, ParserContext parserContext) {
+		BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(
+				"org.springframework.scheduling.support.MethodInvokingRunnable");
+		builder.addPropertyReference("targetObject", ref);
+		builder.addPropertyValue("targetMethod", method);
+		return parserContext.getReaderContext().registerWithGeneratedName(builder.getBeanDefinition());
+	}
+
+}

org.springframework.context/src/main/java/org/springframework/scheduling/config/SchedulingNamespaceHandler.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2002-2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.scheduling.config;
+
+import org.springframework.beans.factory.xml.NamespaceHandlerSupport;
+
+/**
+ * <code>NamespaceHandler</code> for the scheduling namespace. 
+ * 
+ * @author Mark Fisher
+ * @since 3.0
+ */
+public class SchedulingNamespaceHandler extends NamespaceHandlerSupport {
+
+	public void init() {
+		this.registerBeanDefinitionParser("scheduled-tasks", new ScheduledTasksBeanDefinitionParser());
+	}
+
+}