INT-28 committing non-annotation based ExpressionSource implementation

org.springframework.integration/src/main/java/org/springframework/integration/aop/MethodNameMappingExpressionSource.java

@@ -0,0 +1,130 @@
+/*
+ * 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.integration.aop;
+
+import java.lang.reflect.Method;
+import java.util.Collections;
+import java.util.Map;
+
+import org.springframework.core.LocalVariableTableParameterNameDiscoverer;
+import org.springframework.core.ParameterNameDiscoverer;
+import org.springframework.util.Assert;
+import org.springframework.util.PatternMatchUtils;
+
+/**
+ * @author Mark Fisher
+ * @since 2.0
+ */
+public class MethodNameMappingExpressionSource implements ExpressionSource {
+
+	private final Map<String, String> payloadExpressionMap;
+
+	private volatile Map<String, String[]> headerExpressionMap = Collections.emptyMap();
+
+	private volatile Map<String, String> channelMap = Collections.emptyMap();
+
+	private volatile Map<String, String[]> argNameMap;
+
+	private volatile String argumentMapName = ExpressionSource.DEFAULT_ARGUMENT_MAP_NAME;
+
+	private volatile String returnValueName = ExpressionSource.DEFAULT_RETURN_VALUE_NAME;
+
+	private volatile String exceptionName = ExpressionSource.DEFAULT_EXCEPTION_NAME;
+
+	private final ParameterNameDiscoverer parameterNameDiscoverer = new LocalVariableTableParameterNameDiscoverer();
+
+
+	public MethodNameMappingExpressionSource(Map<String, String> payloadExpressionMap) {
+		Assert.notEmpty(payloadExpressionMap, "payloadExpressionMap must not be empty");
+		this.payloadExpressionMap = payloadExpressionMap;
+	}
+
+	public void setArgumentMapName(String argumentMapName) {
+		this.argumentMapName = argumentMapName;
+	}
+
+	public String getArgumentMapName(Method method) {
+		return this.argumentMapName;
+	}
+
+	public void setExceptionName(String exceptionName) {
+		this.exceptionName = exceptionName;
+	}
+
+	public String getExceptionName(Method method) {
+		return this.exceptionName;
+	}
+
+	public void setReturnValueName(String returnValueName) {
+		this.returnValueName = returnValueName;
+	}
+
+	public String getReturnValueName(Method method) {
+		return this.returnValueName;
+	}
+
+	public void setArgNameMap(Map<String, String[]> argNameMap) {
+		this.argNameMap = argNameMap;
+	}
+
+	public void setHeaderExpressionMap(Map<String, String[]> headerExpressionMap) {
+		this.headerExpressionMap = headerExpressionMap;
+	}
+
+	public void setChannelMap(Map<String, String> channelMap) {
+		this.channelMap = channelMap;
+	}
+
+	public String[] getArgumentNames(Method method) {
+		if (this.argNameMap != null) {
+			for (Map.Entry<String, String[]> entry : this.argNameMap.entrySet()) {
+				if (PatternMatchUtils.simpleMatch(entry.getKey(), method.getName())) {
+					return entry.getValue();
+				}
+			}
+		}
+		return this.parameterNameDiscoverer.getParameterNames(method);
+	}
+
+	public String getPayloadExpression(Method method) {
+		for (Map.Entry<String, String> entry : this.payloadExpressionMap.entrySet()) {
+			if (PatternMatchUtils.simpleMatch(entry.getKey(), method.getName())) {
+				return entry.getValue();
+			}
+		}
+		return null;
+	}
+
+	public String[] getHeaderExpressions(Method method) {
+		for (Map.Entry<String, String[]> entry : this.headerExpressionMap.entrySet()) {
+			if (PatternMatchUtils.simpleMatch(entry.getKey(), method.getName())) {
+				return entry.getValue();
+			}
+		}
+		return null;
+	}
+
+	public String getChannelName(Method method) {
+		for (Map.Entry<String, String> entry : this.channelMap.entrySet()) {
+			if (PatternMatchUtils.simpleMatch(entry.getKey(), method.getName())) {
+				return entry.getValue();
+			}
+		}
+		return null;
+	}
+
+}