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

Upgrade dependencies; prepare for release

Browse Source
This commit is contained in:
Artem Bilan
2020-04-29 14:28:14 -04:00
committed by Artem Bilan
parent 8771f8e18c
commit a28647259c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PollableKafkaChannel.java
View File

@@ -23,7 +23,6 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.springframework.integration.channel.ExecutorChannelInterceptorAware;
import org.springframework.integration.kafka.inbound.KafkaMessageSource;
import org.springframework.integration.support.management.PollableChannelManagement;
import org.springframework.integration.support.management.metrics.CounterFacade;
import org.springframework.integration.support.management.metrics.MetricsCaptor;
import org.springframework.kafka.core.KafkaOperations;
@@ -38,11 +37,14 @@ import org.springframework.util.Assert;
* Pollable channel backed by a Kafka topic.
*
* @author Gary Russell
*
* @since 3.3
*
*/
@SuppressWarnings("deprecation")
public class PollableKafkaChannel extends AbstractKafkaChannel
implements PollableChannel, PollableChannelManagement, ExecutorChannelInterceptorAware {
implements PollableChannel, org.springframework.integration.support.management.PollableChannelManagement,
ExecutorChannelInterceptorAware {
private final KafkaMessageSource<?, ?> source;