diff --git a/spring-integration-core/src/main/java/org/springframework/integration/config/dsl/IntegrationFlowBeanPostProcessor.java b/spring-integration-core/src/main/java/org/springframework/integration/config/dsl/IntegrationFlowBeanPostProcessor.java
index 2216f9ff17..974c467b7f 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/config/dsl/IntegrationFlowBeanPostProcessor.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/config/dsl/IntegrationFlowBeanPostProcessor.java
@@ -160,11 +160,7 @@ public class IntegrationFlowBeanPostProcessor
 					id = flowNamePrefix + id;
 				}
 
-				Collection<?> messageHandlers =
-						this.beanFactory.getBeansOfType(messageHandler.getClass(), false, false)
-								.values();
-
-				if (!messageHandlers.contains(messageHandler)) {
+				if (noBeanPresentForComponent(messageHandler)) {
 					String handlerBeanName = generateBeanName(messageHandler, flowNamePrefix);
 
 					registerComponent(messageHandler, handlerBeanName, flowBeanName);
@@ -175,8 +171,7 @@ public class IntegrationFlowBeanPostProcessor
 				targetIntegrationComponents.put(endpoint, id);
 			}
 			else {
-				Collection<?> values = this.beanFactory.getBeansOfType(component.getClass(), false, false).values();
-				if (!values.contains(component)) {
+				if (noBeanPresentForComponent(component)) {
 					if (component instanceof AbstractMessageChannel) {
 						String channelBeanName = ((AbstractMessageChannel) component).getComponentName();
 						if (channelBeanName == null) {
@@ -213,10 +208,7 @@ public class IntegrationFlowBeanPostProcessor
 						if (!CollectionUtils.isEmpty(componentsToRegister)) {
 							componentsToRegister.entrySet()
 									.stream()
-									.filter(o ->
-											!this.beanFactory.getBeansOfType(o.getKey().getClass(), false, false)
-													.values()
-													.contains(o.getKey()))
+									.filter(o -> noBeanPresentForComponent(o.getKey()))
 									.forEach(o ->
 											registerComponent(o.getKey(),
 													generateBeanName(o.getKey(), flowNamePrefix, o.getValue(),
@@ -236,9 +228,7 @@ public class IntegrationFlowBeanPostProcessor
 						targetIntegrationComponents.put(pollingChannelAdapterFactoryBean, id);
 
 						MessageSource<?> messageSource = spec.get().getT2();
-						if (!this.beanFactory.getBeansOfType(messageSource.getClass(), false, false)
-								.values()
-								.contains(messageSource)) {
+						if (noBeanPresentForComponent(messageSource)) {
 							String messageSourceId = id + ".source";
 							if (messageSource instanceof NamedComponent
 									&& ((NamedComponent) messageSource).getComponentName() != null) {
@@ -311,10 +301,7 @@ public class IntegrationFlowBeanPostProcessor
 
 				componentsToRegister.entrySet()
 						.stream()
-						.filter(component ->
-								!this.beanFactory.getBeansOfType(component.getKey().getClass(), false, false)
-										.values()
-										.contains(component.getKey()))
+						.filter(component -> noBeanPresentForComponent(component.getKey()))
 						.forEach(component ->
 								registerComponent(component.getKey(),
 										generateBeanName(component.getKey(), component.getValue())));
@@ -355,6 +342,19 @@ public class IntegrationFlowBeanPostProcessor
 		}
 	}
 
+	private boolean noBeanPresentForComponent(Object instance) {
+		if (instance instanceof NamedComponent) {
+			String beanName = ((NamedComponent) instance).getComponentName();
+			if (beanName != null) {
+				return !this.beanFactory.containsBean(beanName);
+			}
+		}
+
+		Collection<?> beans = this.beanFactory.getBeansOfType(instance.getClass(), false, false).values();
+
+		return !beans.contains(instance);
+	}
+
 	private void registerComponent(Object component, String beanName) {
 		registerComponent(component, beanName, null);
 	}
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationComponentSpec.java b/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationComponentSpec.java
index 71bd0f8533..5b58ce103c 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationComponentSpec.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationComponentSpec.java
@@ -63,7 +63,7 @@ public abstract class IntegrationComponentSpec<S extends IntegrationComponentSpe
 	/**
 	 * @return the configured component.
 	 */
-	public final T get() {
+	public T get() {
 		if (this.target == null) {
 			this.target = doGet();
 		}
@@ -71,7 +71,7 @@ public abstract class IntegrationComponentSpec<S extends IntegrationComponentSpe
 	}
 
 	@Override
-	public T getObject() throws Exception {
+	public T getObject() {
 		return get();
 	}
 
@@ -80,11 +80,6 @@ public abstract class IntegrationComponentSpec<S extends IntegrationComponentSpe
 		return get().getClass();
 	}
 
-	@Override
-	public boolean isSingleton() {
-		return true;
-	}
-
 	@Override
 	public void afterPropertiesSet() throws Exception {
 		if (this.target instanceof InitializingBean) {
diff --git a/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java b/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java
index 6e60369fc8..20d9fb2763 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java
@@ -20,6 +20,7 @@ import static org.hamcrest.Matchers.containsString;
 import static org.hamcrest.Matchers.instanceOf;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNotSame;
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertSame;
 import static org.junit.Assert.assertThat;
@@ -44,11 +45,13 @@ import org.springframework.beans.factory.BeanCreationException;
 import org.springframework.beans.factory.ListableBeanFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.config.ConfigurableBeanFactory;
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Scope;
 import org.springframework.integration.MessageDispatchingException;
 import org.springframework.integration.MessageRejectedException;
 import org.springframework.integration.annotation.MessageEndpoint;
@@ -64,6 +67,7 @@ import org.springframework.integration.dsl.IntegrationFlows;
 import org.springframework.integration.dsl.Pollers;
 import org.springframework.integration.dsl.Transformers;
 import org.springframework.integration.dsl.channel.MessageChannels;
+import org.springframework.integration.endpoint.EventDrivenConsumer;
 import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
 import org.springframework.integration.handler.GenericHandler;
 import org.springframework.integration.handler.advice.ErrorMessageSendingRecoverer;
@@ -475,6 +479,18 @@ public class IntegrationFlowTests {
 		assertEquals("dedicatedTaskScheduler-1", threadNameReference.get());
 	}
 
+	@Autowired
+	private EventDrivenConsumer flow1WithPrototypeHandlerConsumer;
+
+	@Autowired
+	private EventDrivenConsumer flow2WithPrototypeHandlerConsumer;
+
+	@Test
+	public void testPrototypeIsNotOverridden() {
+		assertNotSame(this.flow1WithPrototypeHandlerConsumer.getHandler(),
+				this.flow2WithPrototypeHandlerConsumer.getHandler());
+	}
+
 	@MessagingGateway
 	public interface ControlBusGateway {
 
@@ -841,6 +857,31 @@ public class IntegrationFlowTests {
 			return new ThreadPoolTaskScheduler();
 		}
 
+		@Bean
+		@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
+		public AbstractReplyProducingMessageHandler myHandler() {
+			return new AbstractReplyProducingMessageHandler() {
+
+				@Override
+				protected Object handleRequestMessage(Message<?> requestMessage) {
+					return requestMessage;
+				}
+
+			};
+		}
+
+		@Bean
+		public IntegrationFlow flow1WithPrototypeHandler(
+				@Qualifier("myHandler") AbstractReplyProducingMessageHandler handler) {
+			return f -> f.handle(handler, e -> e.id("flow1WithPrototypeHandlerConsumer"));
+		}
+
+		@Bean
+		public IntegrationFlow flow2WithPrototypeHandler(
+				@Qualifier("myHandler") AbstractReplyProducingMessageHandler handler) {
+			return f -> f.handle(handler, e -> e.id("flow2WithPrototypeHandlerConsumer"));
+		}
+
 	}
 
 	@Service