From fdf1a55112e77283fad9998277bc47561bba8046 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 3 Aug 2018 17:21:14 -0400 Subject: [PATCH] Fix unused imports --- .../stream/binder/kinesis/KinesisMessageChannelBinder.java | 1 - .../stream/binder/kinesis/KinesisBinderProcessorTests.java | 2 -- 2 files changed, 3 deletions(-) diff --git a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/KinesisMessageChannelBinder.java b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/KinesisMessageChannelBinder.java index e104cc0..fbbb6b0 100644 --- a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/KinesisMessageChannelBinder.java +++ b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/KinesisMessageChannelBinder.java @@ -45,7 +45,6 @@ import org.springframework.expression.Expression; import org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter; import org.springframework.integration.aws.inbound.kinesis.KinesisMessageHeaderErrorMessageStrategy; import org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset; -import org.springframework.integration.aws.inbound.kinesis.ListenerMode; import org.springframework.integration.aws.outbound.KinesisMessageHandler; import org.springframework.integration.channel.ChannelInterceptorAware; import org.springframework.integration.core.MessageProducer; diff --git a/spring-cloud-stream-binder-kinesis/src/test/java/org/springframework/cloud/stream/binder/kinesis/KinesisBinderProcessorTests.java b/spring-cloud-stream-binder-kinesis/src/test/java/org/springframework/cloud/stream/binder/kinesis/KinesisBinderProcessorTests.java index fd62673..b018b40 100644 --- a/spring-cloud-stream-binder-kinesis/src/test/java/org/springframework/cloud/stream/binder/kinesis/KinesisBinderProcessorTests.java +++ b/spring-cloud-stream-binder-kinesis/src/test/java/org/springframework/cloud/stream/binder/kinesis/KinesisBinderProcessorTests.java @@ -46,8 +46,6 @@ import org.springframework.integration.aws.support.AwsHeaders; import org.springframework.integration.channel.PublishSubscribeChannel; import org.springframework.integration.channel.QueueChannel; import org.springframework.integration.core.MessageProducer; -import org.springframework.integration.support.locks.DefaultLockRegistry; -import org.springframework.integration.support.locks.LockRegistry; import org.springframework.messaging.Message; import org.springframework.messaging.MessageChannel; import org.springframework.messaging.MessageHeaders;