diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/bus/ApplicationContextMessageBus.java b/org.springframework.integration/src/main/java/org/springframework/integration/bus/ApplicationContextMessageBus.java
index a4c30d68aa..a8690fc447 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/bus/ApplicationContextMessageBus.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/bus/ApplicationContextMessageBus.java
@@ -17,8 +17,6 @@
 package org.springframework.integration.bus;
 
 import java.util.Collection;
-import java.util.Set;
-import java.util.concurrent.CopyOnWriteArraySet;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -54,8 +52,6 @@ public class ApplicationContextMessageBus implements ApplicationContextAware, Ap
 
 	private final Log logger = LogFactory.getLog(this.getClass());
 
-	private final Set<MessageEndpoint> endpoints = new CopyOnWriteArraySet<MessageEndpoint>();
-
 	private volatile TaskScheduler taskScheduler;
 
 	private volatile ApplicationContext applicationContext;
@@ -92,8 +88,7 @@ public class ApplicationContextMessageBus implements ApplicationContextAware, Ap
 
 	private Collection<MessageEndpoint> getEndpoints() {
 		GenericBeanFactoryAccessor accessor = new GenericBeanFactoryAccessor(this.applicationContext);
-		this.endpoints.addAll(accessor.getBeansOfType(MessageEndpoint.class).values());
-		return this.endpoints;
+		return accessor.getBeansOfType(MessageEndpoint.class).values();
 	}
 
 	private void activateEndpoints() {