Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove Lifecyle since it's the super of Pausable

Browse Source
This commit is contained in:
Gary Russell
2019-04-02 12:20:35 -04:00
committed by Artem Bilan
parent ca125a8a6f
commit e76fd2bea2
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageSource.java
View File

@@ -42,7 +42,6 @@ import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.errors.WakeupException;
import org.springframework.context.Lifecycle;
import org.springframework.integration.IntegrationMessageHeaderAccessor;
import org.springframework.integration.acks.AcknowledgmentCallback;
import org.springframework.integration.acks.AcknowledgmentCallbackFactory;
@@ -86,7 +85,7 @@ import org.springframework.util.Assert;
* @since 3.0.1
*
*/
public class KafkaMessageSource<K, V> extends AbstractMessageSource<Object> implements Lifecycle, Pausable {
public class KafkaMessageSource<K, V> extends AbstractMessageSource<Object> implements Pausable {
private static final long DEFAULT_POLL_TIMEOUT = 50L;