From a10e317696f8c86b80ee800f4afe01e05b6e4d2f Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 10 Aug 2020 14:39:26 -0400 Subject: [PATCH] Fix unused import * Fix new Sonar smells --- .../integration/r2dbc/inbound/R2dbcMessageSource.java | 1 - .../redis/inbound/ReactiveRedisStreamMessageProducer.java | 7 +++---- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/inbound/R2dbcMessageSource.java b/spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/inbound/R2dbcMessageSource.java index 1d69e311d8..bad9ef1c04 100644 --- a/spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/inbound/R2dbcMessageSource.java +++ b/spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/inbound/R2dbcMessageSource.java @@ -17,7 +17,6 @@ package org.springframework.integration.r2dbc.inbound; -import java.util.HashMap; import java.util.Map; import java.util.function.BiFunction; diff --git a/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducer.java b/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducer.java index 285acf070d..b1281b9369 100644 --- a/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducer.java +++ b/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducer.java @@ -25,9 +25,7 @@ import org.springframework.data.redis.connection.stream.Record; import org.springframework.data.redis.connection.stream.StreamOffset; import org.springframework.data.redis.core.ReactiveRedisTemplate; import org.springframework.data.redis.core.ReactiveStreamOperations; -import org.springframework.data.redis.core.StreamOperations; import org.springframework.data.redis.serializer.RedisSerializationContext; -import org.springframework.data.redis.serializer.StringRedisSerializer; import org.springframework.data.redis.stream.StreamReceiver; import org.springframework.integration.IntegrationMessageHeaderAccessor; import org.springframework.integration.endpoint.MessageProducerSupport; @@ -146,9 +144,10 @@ public class ReactiveRedisStreamMessageProducer extends MessageProducerSupport { } /** - * Set {@link StreamOperations} used to customize the {@link StreamReceiver}. + * Set {@link ReactiveStreamOperations} used to customize the {@link StreamReceiver}. * It provides a way to set the polling timeout and the serialization context. - * By default the polling timeout is set to infinite and {@link StringRedisSerializer} is used. + * By default the polling timeout is set to infinite and + * {@link org.springframework.data.redis.serializer.StringRedisSerializer} is used. * @param streamReceiverOptions the desired receiver options * */ public void setStreamReceiverOptions(