diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/SubscribingConsumerEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/SubscribingConsumerEndpoint.java index de116f8768..2adc2ad43d 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/SubscribingConsumerEndpoint.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/SubscribingConsumerEndpoint.java @@ -24,7 +24,7 @@ import org.springframework.util.Assert; /** * @author Mark Fisher */ -public class SubscribingConsumerEndpoint implements MessageEndpoint, Lifecycle { +public class SubscribingConsumerEndpoint extends AbstractEndpoint implements Lifecycle { private final MessageConsumer consumer;