Skip to content

Commit a286472

Browse files
committed
Upgrade dependencies; prepare for release
1 parent 8771f8e commit a286472

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323

2424
import org.springframework.integration.channel.ExecutorChannelInterceptorAware;
2525
import org.springframework.integration.kafka.inbound.KafkaMessageSource;
26-
import org.springframework.integration.support.management.PollableChannelManagement;
2726
import org.springframework.integration.support.management.metrics.CounterFacade;
2827
import org.springframework.integration.support.management.metrics.MetricsCaptor;
2928
import org.springframework.kafka.core.KafkaOperations;
@@ -38,11 +37,14 @@
3837
* Pollable channel backed by a Kafka topic.
3938
*
4039
* @author Gary Russell
40+
*
4141
* @since 3.3
4242
*
4343
*/
44+
@SuppressWarnings("deprecation")
4445
public class PollableKafkaChannel extends AbstractKafkaChannel
45-
implements PollableChannel, PollableChannelManagement, ExecutorChannelInterceptorAware {
46+
implements PollableChannel, org.springframework.integration.support.management.PollableChannelManagement,
47+
ExecutorChannelInterceptorAware {
4648

4749
private final KafkaMessageSource<?, ?> source;
4850

0 commit comments

Comments
 (0)