Added ComponentConfigurer.

spring-eai-core/src/main/java/org/springframework/integration/config/ComponentConfigurer.java

@@ -0,0 +1,85 @@
+/*
+ * Copyright 2002-2007 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.config;
+
+import org.springframework.beans.factory.config.RuntimeBeanReference;
+import org.springframework.beans.factory.support.BeanDefinitionRegistry;
+import org.springframework.beans.factory.support.BeanNameGenerator;
+import org.springframework.beans.factory.support.DefaultBeanNameGenerator;
+import org.springframework.beans.factory.support.RootBeanDefinition;
+import org.springframework.integration.endpoint.GenericMessageEndpoint;
+import org.springframework.integration.endpoint.InboundMethodInvokingChannelAdapter;
+import org.springframework.integration.endpoint.MessageHandlerAdapter;
+import org.springframework.integration.endpoint.OutboundMethodInvokingChannelAdapter;
+import org.springframework.util.Assert;
+
+/**
+ * Factory for creating integration component bean definitions.
+ * 
+ * @author Mark Fisher
+ */
+public class ComponentConfigurer {
+
+	private BeanDefinitionRegistry registry;
+
+	private BeanNameGenerator beanNameGenerator;
+
+
+	public ComponentConfigurer(BeanDefinitionRegistry registry, BeanNameGenerator beanNameGenerator) {
+		Assert.notNull(registry, "registry must not be null");
+		this.registry = registry;
+		this.beanNameGenerator = (beanNameGenerator != null ? beanNameGenerator : new DefaultBeanNameGenerator());
+	}
+
+	public String serviceActivator(String inputChannel, String outputChannel, String objectRef, String method) {
+		RootBeanDefinition endpointDef = new RootBeanDefinition(GenericMessageEndpoint.class);
+		RootBeanDefinition adapterDef = new RootBeanDefinition(MessageHandlerAdapter.class);
+		adapterDef.getPropertyValues().addPropertyValue("object", new RuntimeBeanReference(objectRef));
+		adapterDef.getPropertyValues().addPropertyValue("method", method);
+		String adapterName = beanNameGenerator.generateBeanName(adapterDef, this.registry);
+		this.registry.registerBeanDefinition(adapterName, adapterDef);
+		endpointDef.getPropertyValues().addPropertyValue("handler", new RuntimeBeanReference(adapterName));
+		if (inputChannel != null) {
+			endpointDef.getPropertyValues().addPropertyValue("inputChannelName", inputChannel);
+		}
+		if (outputChannel != null) {
+			endpointDef.getPropertyValues().addPropertyValue("defaultOutputChannelName", outputChannel);
+		}
+		String endpointName = beanNameGenerator.generateBeanName(endpointDef, this.registry);
+		this.registry.registerBeanDefinition(endpointName, endpointDef);
+		return endpointName;
+	}
+
+	public String inboundChannelAdapter(String objectRef, String method) {
+		RootBeanDefinition bd = new RootBeanDefinition(InboundMethodInvokingChannelAdapter.class);
+		bd.getPropertyValues().addPropertyValue("object", new RuntimeBeanReference(objectRef));
+		bd.getPropertyValues().addPropertyValue("method", method);
+		String beanName = this.beanNameGenerator.generateBeanName(bd, this.registry);
+		this.registry.registerBeanDefinition(beanName, bd);
+		return beanName;
+	}
+
+	public String outboundChannelAdapter(String objectRef, String method) {
+		RootBeanDefinition bd = new RootBeanDefinition(OutboundMethodInvokingChannelAdapter.class);
+		bd.getPropertyValues().addPropertyValue("object", new RuntimeBeanReference(objectRef));
+		bd.getPropertyValues().addPropertyValue("method", method);
+		String beanName = this.beanNameGenerator.generateBeanName(bd, this.registry);
+		this.registry.registerBeanDefinition(beanName, bd);
+		return beanName;
+	}
+
+}

spring-eai-core/src/test/java/org/springframework/integration/config/ComponentConfigurerTests.java

@@ -0,0 +1,100 @@
+/*
+ * Copyright 2002-2007 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.config;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import org.junit.Test;
+
+import org.springframework.beans.factory.support.RootBeanDefinition;
+import org.springframework.context.support.GenericApplicationContext;
+import org.springframework.integration.bus.MessageBus;
+import org.springframework.integration.channel.MessageChannel;
+import org.springframework.integration.channel.PointToPointChannel;
+import org.springframework.integration.endpoint.MessageEndpoint;
+import org.springframework.integration.message.DocumentMessage;
+import org.springframework.integration.message.Message;
+
+/**
+ * @author Mark Fisher
+ */
+public class ComponentConfigurerTests {
+
+	@Test
+	public void testServiceActivator() {
+		GenericApplicationContext context = new GenericApplicationContext();
+		ComponentConfigurer cr = new ComponentConfigurer(context, null);
+		context.registerBeanDefinition("tester", new RootBeanDefinition(Tester.class));
+		context.registerBeanDefinition("out", new RootBeanDefinition(PointToPointChannel.class));
+		context.registerBeanDefinition("bus", new RootBeanDefinition(MessageBus.class));
+		String name = cr.serviceActivator("in", "out", "tester", "test");
+		context.refresh();
+		MessageEndpoint endpoint = (MessageEndpoint) context.getBean(name);
+		endpoint.messageReceived(new DocumentMessage(1, "world"));
+		MessageChannel channel = (MessageChannel) context.getBean("out");
+		assertEquals("hello world", channel.receive().getPayload());
+	}
+
+	@Test
+	public void testInboundChannelAdapter() {
+		GenericApplicationContext context = new GenericApplicationContext();
+		ComponentConfigurer cr = new ComponentConfigurer(context, null);
+		context.registerBeanDefinition("tester", new RootBeanDefinition(Tester.class));
+		String adapter = cr.inboundChannelAdapter("tester", "foo");
+		MessageChannel channel = (MessageChannel) context.getBean(adapter);
+		Message message = channel.receive();
+		assertEquals("bar", message.getPayload());
+	}
+
+	@Test
+	public void testOutboundChannelAdapter() {
+		GenericApplicationContext context = new GenericApplicationContext();
+		ComponentConfigurer cr = new ComponentConfigurer(context, null);
+		context.registerBeanDefinition("tester", new RootBeanDefinition(Tester.class));
+		String adapter = cr.outboundChannelAdapter("tester", "store");
+		Tester tester = (Tester) context.getBean("tester");
+		assertNull(tester.getStoredValue());
+		MessageChannel channel = (MessageChannel) context.getBean(adapter);
+		boolean result = channel.send(new DocumentMessage(1, "foo"));
+		assertTrue(result);
+		assertEquals("foo", tester.getStoredValue());
+	}
+
+
+	public static class Tester {
+
+		private String storedValue;
+
+		public String test(String s) {
+			return "hello " + s;
+		}
+
+		public String foo() {
+			return "bar";
+		}
+
+		public void store(String s) {
+			this.storedValue = s;
+		}
+
+		public String getStoredValue() {
+			return this.storedValue;
+		}
+	}
+}