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

Fix deprecation warning

Browse Source
This commit is contained in:
Artem Bilan
2015-11-17 17:01:59 -05:00
committed by Artem Bilan
parent d6a3b343aa
commit 9208f74347
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaHighLevelConsumerMessageSource.java
View File

@@ -20,7 +20,6 @@ import java.util.Map;
import org.springframework.integration.context.IntegrationObjectSupport;
import org.springframework.integration.core.MessageSource;
import org.springframework.integration.kafka.support.KafkaConsumerContext;
import org.springframework.messaging.Message;
/**
@@ -29,11 +28,12 @@ import org.springframework.messaging.Message;
* @deprecated since 1.3 in favor of {@link KafkaMessageDrivenChannelAdapter}
*/
@Deprecated
@SuppressWarnings("deprecation")
public class KafkaHighLevelConsumerMessageSource<K,V> extends IntegrationObjectSupport implements MessageSource<Map<String, Map<Integer, List<Object>>>> {
private final KafkaConsumerContext<K,V> kafkaConsumerContext;
private final org.springframework.integration.kafka.support.KafkaConsumerContext<K,V> kafkaConsumerContext;
public KafkaHighLevelConsumerMessageSource(final KafkaConsumerContext<K,V> kafkaConsumerContext) {
public KafkaHighLevelConsumerMessageSource(final org.springframework.integration.kafka.support.KafkaConsumerContext<K,V> kafkaConsumerContext) {
this.kafkaConsumerContext = kafkaConsumerContext;
}