From cdb3e2437da7d4bfc3e18ac1ae901b936f8166e2 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Mon, 21 Aug 2017 11:58:57 +0200 Subject: [PATCH] DATAREDIS-681 - Polishing. Remove final keywords from variables in ClusterCommandExecutor. Reduce constructor visibility of driver-specific commands classes. Fix Javadoc. Original Pull Request: #267 --- .../connection/ClusterCommandExecutor.java | 18 +++++++++--------- .../jedis/JedisClusterGeoCommands.java | 3 ++- .../jedis/JedisClusterHashCommands.java | 3 ++- .../jedis/JedisClusterHyperLogLogCommands.java | 3 ++- .../jedis/JedisClusterKeyCommands.java | 2 +- .../jedis/JedisClusterListCommands.java | 2 +- .../jedis/JedisClusterServerCommands.java | 2 +- .../jedis/JedisClusterSetCommands.java | 2 +- .../jedis/JedisClusterStringCommands.java | 2 +- .../jedis/JedisClusterZSetCommands.java | 3 ++- .../connection/jedis/JedisGeoCommands.java | 3 ++- .../connection/jedis/JedisHashCommands.java | 3 ++- .../jedis/JedisHyperLogLogCommands.java | 3 ++- .../connection/jedis/JedisKeyCommands.java | 3 ++- .../connection/jedis/JedisListCommands.java | 3 ++- .../jedis/JedisScriptingCommands.java | 16 ++++++++-------- .../connection/jedis/JedisServerCommands.java | 2 +- .../connection/jedis/JedisSetCommands.java | 3 ++- .../connection/jedis/JedisStringCommands.java | 3 ++- .../lettuce/LettuceClusterGeoCommands.java | 3 ++- .../lettuce/LettuceClusterHashCommands.java | 3 ++- .../LettuceClusterHyperLogLogCommands.java | 3 ++- .../lettuce/LettuceClusterKeyCommands.java | 3 ++- .../lettuce/LettuceClusterListCommands.java | 2 +- .../lettuce/LettuceClusterServerCommands.java | 2 +- .../lettuce/LettuceClusterSetCommands.java | 2 +- .../lettuce/LettuceClusterStringCommands.java | 7 ++----- .../lettuce/LettuceClusterZSetCommands.java | 3 ++- .../LettuceReactiveClusterGeoCommands.java | 5 +++-- .../LettuceReactiveClusterHashCommands.java | 5 +++-- ...tuceReactiveClusterHyperLogLogCommands.java | 7 ++++--- .../LettuceReactiveClusterKeyCommands.java | 4 ++-- .../LettuceReactiveClusterListCommands.java | 4 ++-- .../LettuceReactiveClusterNumberCommands.java | 5 +++-- .../LettuceReactiveClusterServerCommands.java | 4 ++-- .../LettuceReactiveClusterSetCommands.java | 4 ++-- .../LettuceReactiveClusterStringCommands.java | 5 +++-- .../LettuceReactiveClusterZSetCommands.java | 7 ++++--- .../lettuce/LettuceReactiveGeoCommands.java | 3 ++- .../lettuce/LettuceReactiveHashCommands.java | 2 +- .../LettuceReactiveHyperLogLogCommands.java | 4 +++- .../lettuce/LettuceReactiveKeyCommands.java | 2 +- .../lettuce/LettuceReactiveListCommands.java | 2 +- .../lettuce/LettuceReactiveNumberCommands.java | 4 ++-- .../lettuce/LettuceReactiveSetCommands.java | 2 +- .../lettuce/LettuceReactiveStringCommands.java | 2 +- .../lettuce/LettuceReactiveZSetCommands.java | 4 ++-- .../lettuce/LettuceScriptingCommands.java | 16 ++++++++-------- .../lettuce/LettuceServerCommands.java | 2 +- .../connection/lettuce/LettuceSetCommands.java | 3 ++- .../lettuce/LettuceStringCommands.java | 3 ++- .../lettuce/LettuceZSetCommands.java | 3 ++- 52 files changed, 117 insertions(+), 92 deletions(-) diff --git a/src/main/java/org/springframework/data/redis/connection/ClusterCommandExecutor.java b/src/main/java/org/springframework/data/redis/connection/ClusterCommandExecutor.java index fcd101bbb..5f2f8146e 100644 --- a/src/main/java/org/springframework/data/redis/connection/ClusterCommandExecutor.java +++ b/src/main/java/org/springframework/data/redis/connection/ClusterCommandExecutor.java @@ -182,7 +182,7 @@ public class ClusterCommandExecutor implements DisposableBean { * @throws ClusterCommandExecutionFailureException * @throws IllegalArgumentException in case the node could not be resolved to a topology-known node */ - public MultiNodeResult executeCommandAsyncOnNodes(final ClusterCommandCallback callback, + public MultiNodeResult executeCommandAsyncOnNodes(ClusterCommandCallback callback, Iterable nodes) { Assert.notNull(callback, "Callback must not be null!"); @@ -191,7 +191,7 @@ public class ClusterCommandExecutor implements DisposableBean { List resolvedRedisClusterNodes = new ArrayList<>(); ClusterTopology topology = topologyProvider.getTopology(); - for (final RedisClusterNode node : nodes) { + for (RedisClusterNode node : nodes) { try { resolvedRedisClusterNodes.add(topology.lookup(node)); } catch (ClusterStateFailureException e) { @@ -200,7 +200,7 @@ public class ClusterCommandExecutor implements DisposableBean { } Map>> futures = new LinkedHashMap<>(); - for (final RedisClusterNode node : resolvedRedisClusterNodes) { + for (RedisClusterNode node : resolvedRedisClusterNodes) { futures.put(new NodeExecution(node), executor.submit(() -> executeCommandOnSingleNode(callback, node))); } @@ -267,7 +267,7 @@ public class ClusterCommandExecutor implements DisposableBean { * @return * @throws ClusterCommandExecutionFailureException */ - public MultiNodeResult executeMultiKeyCommand(final MultiKeyClusterCommandCallback cmd, + public MultiNodeResult executeMultiKeyCommand(MultiKeyClusterCommandCallback cmd, Iterable keys) { Map> nodeKeyMap = new HashMap<>(); @@ -287,10 +287,10 @@ public class ClusterCommandExecutor implements DisposableBean { Map>> futures = new LinkedHashMap<>(); - for (final Entry> entry : nodeKeyMap.entrySet()) { + for (Entry> entry : nodeKeyMap.entrySet()) { if (entry.getKey().isMaster()) { - for (final byte[] key : entry.getValue()) { + for (byte[] key : entry.getValue()) { futures.put(new NodeExecution(entry.getKey(), key), executor.submit(() -> executeMultiKeyCommandOnSingleNode(cmd, entry.getKey(), key))); } @@ -363,7 +363,7 @@ public class ClusterCommandExecutor implements DisposableBean { * @param * @since 1.7 */ - public static interface ClusterCommandCallback { + public interface ClusterCommandCallback { S doInCluster(T client); } @@ -374,7 +374,7 @@ public class ClusterCommandExecutor implements DisposableBean { * @param native driver connection * @param */ - public static interface MultiKeyClusterCommandCallback { + public interface MultiKeyClusterCommandCallback { S doInCluster(T client, byte[] key); } @@ -550,7 +550,7 @@ public class ClusterCommandExecutor implements DisposableBean { public List resultsAsListSortBy(byte[]... keys) { ArrayList> clone = new ArrayList<>(nodeResults); - Collections.sort(clone, new ResultByReferenceKeyPositionComparator(keys)); + clone.sort(new ResultByReferenceKeyPositionComparator(keys)); return toList(clone); } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterGeoCommands.java index d81390e45..ab6380a4f 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterGeoCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterGeoCommands.java @@ -34,13 +34,14 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisClusterGeoCommands implements RedisGeoCommands { private final JedisClusterConnection connection; - public JedisClusterGeoCommands(JedisClusterConnection connection) { + JedisClusterGeoCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHashCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHashCommands.java index 66842439e..0fdf08dd4 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHashCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHashCommands.java @@ -32,13 +32,14 @@ import org.springframework.data.redis.core.ScanOptions; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisClusterHashCommands implements RedisHashCommands { private final JedisClusterConnection connection; - public JedisClusterHashCommands(JedisClusterConnection connection) { + JedisClusterHashCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHyperLogLogCommands.java index c03a4e8e5..5bd982b71 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHyperLogLogCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterHyperLogLogCommands.java @@ -23,13 +23,14 @@ import org.springframework.data.redis.util.ByteUtils; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisClusterHyperLogLogCommands implements RedisHyperLogLogCommands { private final JedisClusterConnection connection; - public JedisClusterHyperLogLogCommands(JedisClusterConnection connection) { + JedisClusterHyperLogLogCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterKeyCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterKeyCommands.java index 5e285eec6..850995ffd 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterKeyCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterKeyCommands.java @@ -49,7 +49,7 @@ class JedisClusterKeyCommands implements RedisKeyCommands { private final JedisClusterConnection connection; - public JedisClusterKeyCommands(JedisClusterConnection connection) { + JedisClusterKeyCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterListCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterListCommands.java index 228d000f0..ed4f60856 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterListCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterListCommands.java @@ -34,7 +34,7 @@ class JedisClusterListCommands implements RedisListCommands { private final JedisClusterConnection connection; - public JedisClusterListCommands(JedisClusterConnection connection) { + JedisClusterListCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterServerCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterServerCommands.java index 9bbe330bf..ac7cdb23a 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterServerCommands.java @@ -44,7 +44,7 @@ class JedisClusterServerCommands implements RedisClusterServerCommands { private final JedisClusterConnection connection; - public JedisClusterServerCommands(JedisClusterConnection connection) { + JedisClusterServerCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterSetCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterSetCommands.java index 5144760de..1ee8cdef6 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterSetCommands.java @@ -44,7 +44,7 @@ class JedisClusterSetCommands implements RedisSetCommands { private final JedisClusterConnection connection; - public JedisClusterSetCommands(JedisClusterConnection connection) { + JedisClusterSetCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStringCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStringCommands.java index 0aa443abb..172e6ad52 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterStringCommands.java @@ -40,7 +40,7 @@ class JedisClusterStringCommands implements RedisStringCommands { private final JedisClusterConnection connection; - public JedisClusterStringCommands(JedisClusterConnection jedisClusterConnection) { + JedisClusterStringCommands(JedisClusterConnection jedisClusterConnection) { this.connection = jedisClusterConnection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterZSetCommands.java index 9d72bc957..9d903b21c 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterZSetCommands.java @@ -33,6 +33,7 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @author Clement Ong * @since 2.0 */ @@ -40,7 +41,7 @@ class JedisClusterZSetCommands implements RedisZSetCommands { private final JedisClusterConnection connection; - public JedisClusterZSetCommands(JedisClusterConnection connection) { + JedisClusterZSetCommands(JedisClusterConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisGeoCommands.java index 42696413d..0fb03836f 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisGeoCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisGeoCommands.java @@ -35,13 +35,14 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisGeoCommands implements RedisGeoCommands { private final JedisConnection connection; - public JedisGeoCommands(JedisConnection connection) { + JedisGeoCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisHashCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisHashCommands.java index 9f46406f6..0e702766c 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisHashCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisHashCommands.java @@ -32,13 +32,14 @@ import org.springframework.data.redis.core.ScanOptions; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisHashCommands implements RedisHashCommands { private final JedisConnection connection; - public JedisHashCommands(JedisConnection connection) { + JedisHashCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisHyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisHyperLogLogCommands.java index 3909b4038..a1c0b2f11 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisHyperLogLogCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisHyperLogLogCommands.java @@ -21,13 +21,14 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisHyperLogLogCommands implements RedisHyperLogLogCommands { private final JedisConnection connection; - public JedisHyperLogLogCommands(JedisConnection connection) { + JedisHyperLogLogCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisKeyCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisKeyCommands.java index e0fb740ed..27dcdbd9c 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisKeyCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisKeyCommands.java @@ -35,13 +35,14 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisKeyCommands implements RedisKeyCommands { private final JedisConnection connection; - public JedisKeyCommands(JedisConnection connection) { + JedisKeyCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisListCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisListCommands.java index b9165cf29..3b2b9db57 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisListCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisListCommands.java @@ -25,13 +25,14 @@ import org.springframework.data.redis.connection.jedis.JedisConnection.JedisResu /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisListCommands implements RedisListCommands { private final JedisConnection connection; - public JedisListCommands(JedisConnection connection) { + JedisListCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisScriptingCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisScriptingCommands.java index 5f3fd3656..395ccab33 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisScriptingCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisScriptingCommands.java @@ -28,11 +28,11 @@ class JedisScriptingCommands implements RedisScriptingCommands { private final JedisConnection connection; - public JedisScriptingCommands(JedisConnection connection) { + JedisScriptingCommands(JedisConnection connection) { this.connection = connection; } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptFlush() */ @@ -51,7 +51,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptKill() */ @@ -70,7 +70,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptLoad(byte[]) */ @@ -89,7 +89,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptExists(java.lang.String[]) */ @@ -108,7 +108,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#eval(byte[], org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ @@ -129,7 +129,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#evalSha(java.lang.String, org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ @@ -138,7 +138,7 @@ class JedisScriptingCommands implements RedisScriptingCommands { return evalSha(JedisConverters.toBytes(scriptSha1), returnType, numKeys, keysAndArgs); } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#evalSha(byte[], org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisServerCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisServerCommands.java index aa03ee502..a66303a83 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisServerCommands.java @@ -36,7 +36,7 @@ class JedisServerCommands implements RedisServerCommands { private final JedisConnection connection; - public JedisServerCommands(JedisConnection connection) { + JedisServerCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisSetCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisSetCommands.java index 003d3acaa..1f57a6dd1 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisSetCommands.java @@ -30,13 +30,14 @@ import org.springframework.data.redis.core.ScanOptions; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisSetCommands implements RedisSetCommands { private final JedisConnection connection; - public JedisSetCommands(JedisConnection connection) { + JedisSetCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisStringCommands.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisStringCommands.java index 9adffca78..cc78a8197 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisStringCommands.java @@ -26,13 +26,14 @@ import org.springframework.util.ObjectUtils; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class JedisStringCommands implements RedisStringCommands { private final JedisConnection connection; - public JedisStringCommands(JedisConnection connection) { + JedisStringCommands(JedisConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterGeoCommands.java index a19de75d2..942cf0fc9 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterGeoCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterGeoCommands.java @@ -17,11 +17,12 @@ package org.springframework.data.redis.connection.lettuce; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterGeoCommands extends LettuceGeoCommands { - public LettuceClusterGeoCommands(LettuceClusterConnection connection) { + LettuceClusterGeoCommands(LettuceClusterConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHashCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHashCommands.java index 72b5d74be..9f8368a53 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHashCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHashCommands.java @@ -17,11 +17,12 @@ package org.springframework.data.redis.connection.lettuce; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterHashCommands extends LettuceHashCommands { - public LettuceClusterHashCommands(LettuceClusterConnection connection) { + LettuceClusterHashCommands(LettuceClusterConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHyperLogLogCommands.java index 6c14ddb40..3c673cf46 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHyperLogLogCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterHyperLogLogCommands.java @@ -21,11 +21,12 @@ import org.springframework.data.redis.util.ByteUtils; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterHyperLogLogCommands extends LettuceHyperLogLogCommands { - public LettuceClusterHyperLogLogCommands(LettuceClusterConnection connection) { + LettuceClusterHyperLogLogCommands(LettuceClusterConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterKeyCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterKeyCommands.java index cf2b76086..fcb5aba06 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterKeyCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterKeyCommands.java @@ -33,13 +33,14 @@ import org.springframework.util.CollectionUtils; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterKeyCommands extends LettuceKeyCommands { private final LettuceClusterConnection connection; - public LettuceClusterKeyCommands(LettuceClusterConnection connection) { + LettuceClusterKeyCommands(LettuceClusterConnection connection) { super(connection); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterListCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterListCommands.java index f279455ac..8303d5128 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterListCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterListCommands.java @@ -34,7 +34,7 @@ class LettuceClusterListCommands extends LettuceListCommands { private final LettuceClusterConnection connection; - public LettuceClusterListCommands(LettuceClusterConnection connection) { + LettuceClusterListCommands(LettuceClusterConnection connection) { super(connection); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterServerCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterServerCommands.java index 94071983e..0a518b74f 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterServerCommands.java @@ -43,7 +43,7 @@ class LettuceClusterServerCommands extends LettuceServerCommands implements Redi private final LettuceClusterConnection connection; - public LettuceClusterServerCommands(LettuceClusterConnection connection) { + LettuceClusterServerCommands(LettuceClusterConnection connection) { super(connection); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterSetCommands.java index d8913e110..a1fe2fb66 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterSetCommands.java @@ -36,7 +36,7 @@ class LettuceClusterSetCommands extends LettuceSetCommands { private final LettuceClusterConnection connection; - public LettuceClusterSetCommands(LettuceClusterConnection connection) { + LettuceClusterSetCommands(LettuceClusterConnection connection) { super(connection); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterStringCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterStringCommands.java index f89b75094..ed0343864 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterStringCommands.java @@ -21,16 +21,13 @@ import org.springframework.data.redis.connection.ClusterSlotHashUtil; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterStringCommands extends LettuceStringCommands { - private final LettuceClusterConnection connection; - - public LettuceClusterStringCommands(LettuceClusterConnection connection) { - + LettuceClusterStringCommands(LettuceClusterConnection connection) { super(connection); - this.connection = connection; } /* diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterZSetCommands.java index fc56c9878..f8c346503 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClusterZSetCommands.java @@ -17,11 +17,12 @@ package org.springframework.data.redis.connection.lettuce; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceClusterZSetCommands extends LettuceZSetCommands { - public LettuceClusterZSetCommands(LettuceClusterConnection connection) { + LettuceClusterZSetCommands(LettuceClusterConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterGeoCommands.java index aca8e243c..90a7d9a1d 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterGeoCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterGeoCommands.java @@ -19,16 +19,17 @@ import org.springframework.data.redis.connection.ReactiveClusterGeoCommands; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveClusterGeoCommands extends LettuceReactiveGeoCommands implements ReactiveClusterGeoCommands { /** - * Create new {@link LettuceReactiveGeoCommands}. + * Create new {@link LettuceReactiveClusterGeoCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterGeoCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterGeoCommands(LettuceReactiveRedisConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHashCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHashCommands.java index 0615eea9d..7b3024320 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHashCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHashCommands.java @@ -19,16 +19,17 @@ import org.springframework.data.redis.connection.ReactiveClusterHashCommands; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveClusterHashCommands extends LettuceReactiveHashCommands implements ReactiveClusterHashCommands { /** - * Create new {@link LettuceReactiveHashCommands}. + * Create new {@link LettuceReactiveClusterHashCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterHashCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterHashCommands(LettuceReactiveRedisConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHyperLogLogCommands.java index be2ac6cbb..91f7e55d2 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHyperLogLogCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterHyperLogLogCommands.java @@ -32,17 +32,18 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl - * @since @since 2.0 + * @author Mark Paluch + * @since 2.0 */ class LettuceReactiveClusterHyperLogLogCommands extends LettuceReactiveHyperLogLogCommands implements ReactiveClusterHyperLogLogCommands { /** - * Create new {@link LettuceReactiveHyperLogLogCommands}. + * Create new {@link LettuceReactiveClusterHyperLogLogCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterHyperLogLogCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterHyperLogLogCommands(LettuceReactiveRedisConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterKeyCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterKeyCommands.java index da891ef4b..ad38fc909 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterKeyCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterKeyCommands.java @@ -41,11 +41,11 @@ class LettuceReactiveClusterKeyCommands extends LettuceReactiveKeyCommands imple private LettuceReactiveRedisClusterConnection connection; /** - * Create new {@link LettuceReactiveKeyCommands}. + * Create new {@link LettuceReactiveClusterKeyCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterKeyCommands(LettuceReactiveRedisClusterConnection connection) { + LettuceReactiveClusterKeyCommands(LettuceReactiveRedisClusterConnection connection) { super(connection); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterListCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterListCommands.java index 13caca7a5..207ff579c 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterListCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterListCommands.java @@ -35,11 +35,11 @@ import org.springframework.util.Assert; class LettuceReactiveClusterListCommands extends LettuceReactiveListCommands implements ReactiveClusterListCommands { /** - * Create new {@link LettuceReactiveListCommands}. + * Create new {@link LettuceReactiveClusterListCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterListCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterListCommands(LettuceReactiveRedisConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterNumberCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterNumberCommands.java index b867a67d7..b9e19adac 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterNumberCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterNumberCommands.java @@ -19,17 +19,18 @@ import org.springframework.data.redis.connection.ReactiveClusterNumberCommands; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveClusterNumberCommands extends LettuceReactiveNumberCommands implements ReactiveClusterNumberCommands { /** - * Create new {@link LettuceReactiveStringCommands}. + * Create new {@link LettuceReactiveClusterNumberCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterNumberCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterNumberCommands(LettuceReactiveRedisConnection connection) { super(connection); } } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterServerCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterServerCommands.java index 9b21213f7..35d434db7 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterServerCommands.java @@ -58,14 +58,14 @@ class LettuceReactiveClusterServerCommands extends LettuceReactiveServerCommands private final ClusterTopologyProvider topologyProvider; /** - * Create new {@link LettuceReactiveGeoCommands}. + * Create new {@link LettuceReactiveClusterServerCommands}. * * @param connection must not be {@literal null}. * @param topologyProvider must not be {@literal null}. * @throws IllegalArgumentException when {@code connection} is {@literal null}. * @throws IllegalArgumentException when {@code topologyProvider} is {@literal null}. */ - public LettuceReactiveClusterServerCommands(LettuceReactiveRedisClusterConnection connection, + LettuceReactiveClusterServerCommands(LettuceReactiveRedisClusterConnection connection, ClusterTopologyProvider topologyProvider) { super(connection); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterSetCommands.java index 6bda5093b..63f4c6c81 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterSetCommands.java @@ -39,11 +39,11 @@ import org.springframework.util.Assert; class LettuceReactiveClusterSetCommands extends LettuceReactiveSetCommands implements ReactiveClusterSetCommands { /** - * Create new {@link LettuceReactiveSetCommands}. + * Create new {@link LettuceReactiveClusterSetCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterSetCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterSetCommands(LettuceReactiveRedisConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterStringCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterStringCommands.java index f9ed97fe1..edad273a4 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterStringCommands.java @@ -30,17 +30,18 @@ import org.springframework.data.redis.connection.ReactiveRedisConnection; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveClusterStringCommands extends LettuceReactiveStringCommands implements ReactiveClusterStringCommands { /** - * Create new {@link LettuceReactiveStringCommands}. + * Create new {@link LettuceReactiveClusterStringCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterStringCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterStringCommands(LettuceReactiveRedisConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterZSetCommands.java index cf68db741..81eb0b00c 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveClusterZSetCommands.java @@ -27,16 +27,17 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl - * @since @since 2.0 + * @author Mark Paluch + * @since 2.0 */ class LettuceReactiveClusterZSetCommands extends LettuceReactiveZSetCommands implements ReactiveClusterZSetCommands { /** - * Create new {@link LettuceReactiveSetCommands}. + * Create new {@link LettuceReactiveClusterZSetCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveClusterZSetCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveClusterZSetCommands(LettuceReactiveRedisConnection connection) { super(connection); } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveGeoCommands.java index 247290c2b..622cbb89c 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveGeoCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveGeoCommands.java @@ -43,6 +43,7 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveGeoCommands implements ReactiveGeoCommands { @@ -54,7 +55,7 @@ class LettuceReactiveGeoCommands implements ReactiveGeoCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveGeoCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveGeoCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHashCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHashCommands.java index 3653cef26..8a23b757f 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHashCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHashCommands.java @@ -50,7 +50,7 @@ class LettuceReactiveHashCommands implements ReactiveHashCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveHashCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveHashCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); this.connection = connection; diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHyperLogLogCommands.java index 51f434369..ced544faa 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHyperLogLogCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveHyperLogLogCommands.java @@ -27,6 +27,7 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceReactiveHyperLogLogCommands implements ReactiveHyperLogLogCommands { @@ -38,9 +39,10 @@ class LettuceReactiveHyperLogLogCommands implements ReactiveHyperLogLogCommands * * @param connection must not be {@literal null}. */ - public LettuceReactiveHyperLogLogCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveHyperLogLogCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); + this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommands.java index 82ce5397c..6a7465b50 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommands.java @@ -47,7 +47,7 @@ class LettuceReactiveKeyCommands implements ReactiveKeyCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveKeyCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveKeyCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveListCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveListCommands.java index 46cc03d60..8496ef807 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveListCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveListCommands.java @@ -49,7 +49,7 @@ class LettuceReactiveListCommands implements ReactiveListCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveListCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveListCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveNumberCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveNumberCommands.java index 91c268af3..165cc8410 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveNumberCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveNumberCommands.java @@ -35,11 +35,11 @@ class LettuceReactiveNumberCommands implements ReactiveNumberCommands { private final LettuceReactiveRedisConnection connection; /** - * Create new {@link LettuceReactiveStringCommands}. + * Create new {@link LettuceReactiveNumberCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveNumberCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveNumberCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java index c3c82a549..f915b2e15 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java @@ -43,7 +43,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveSetCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveSetCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveStringCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveStringCommands.java index a0dad24ff..feb4837b2 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveStringCommands.java @@ -49,7 +49,7 @@ class LettuceReactiveStringCommands implements ReactiveStringCommands { * * @param connection must not be {@literal null}. */ - public LettuceReactiveStringCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveStringCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveZSetCommands.java index 5a5fa9023..117bb7844 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveZSetCommands.java @@ -53,11 +53,11 @@ class LettuceReactiveZSetCommands implements ReactiveZSetCommands { private final LettuceReactiveRedisConnection connection; /** - * Create new {@link LettuceReactiveSetCommands}. + * Create new {@link LettuceReactiveZSetCommands}. * * @param connection must not be {@literal null}. */ - public LettuceReactiveZSetCommands(LettuceReactiveRedisConnection connection) { + LettuceReactiveZSetCommands(LettuceReactiveRedisConnection connection) { Assert.notNull(connection, "Connection must not be null!"); diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceScriptingCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceScriptingCommands.java index 235e121e0..fce79a715 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceScriptingCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceScriptingCommands.java @@ -36,11 +36,11 @@ class LettuceScriptingCommands implements RedisScriptingCommands { private final LettuceConnection connection; - public LettuceScriptingCommands(LettuceConnection connection) { + LettuceScriptingCommands(LettuceConnection connection) { this.connection = connection; } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptFlush() */ @@ -61,7 +61,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptKill() */ @@ -85,7 +85,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptLoad(byte[]) */ @@ -106,7 +106,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#scriptExists(java.lang.String[]) */ @@ -127,7 +127,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#eval(byte[], org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ @@ -156,7 +156,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#evalSha(java.lang.String, org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ @@ -185,7 +185,7 @@ class LettuceScriptingCommands implements RedisScriptingCommands { } } - /* + /* * (non-Javadoc) * @see org.springframework.data.redis.connection.RedisScriptingCommands#evalSha(byte[], org.springframework.data.redis.connection.ReturnType, int, byte[][]) */ diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceServerCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceServerCommands.java index 00823d7c8..7cd93a421 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceServerCommands.java @@ -38,7 +38,7 @@ class LettuceServerCommands implements RedisServerCommands { private final LettuceConnection connection; - public LettuceServerCommands(LettuceConnection connection) { + LettuceServerCommands(LettuceConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSetCommands.java index 333bea2de..8e6df4c1c 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSetCommands.java @@ -36,13 +36,14 @@ import org.springframework.data.redis.core.ScanOptions; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceSetCommands implements RedisSetCommands { private final LettuceConnection connection; - public LettuceSetCommands(LettuceConnection connection) { + LettuceSetCommands(LettuceConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStringCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStringCommands.java index 2f6ec2044..79260171a 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStringCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStringCommands.java @@ -30,13 +30,14 @@ import org.springframework.data.redis.core.types.Expiration; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceStringCommands implements RedisStringCommands { private final LettuceConnection connection; - public LettuceStringCommands(LettuceConnection connection) { + LettuceStringCommands(LettuceConnection connection) { this.connection = connection; } diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceZSetCommands.java index 47d1e20f7..7b5409837 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceZSetCommands.java @@ -37,13 +37,14 @@ import org.springframework.util.Assert; /** * @author Christoph Strobl + * @author Mark Paluch * @since 2.0 */ class LettuceZSetCommands implements RedisZSetCommands { private final LettuceConnection connection; - public LettuceZSetCommands(LettuceConnection connection) { + LettuceZSetCommands(LettuceConnection connection) { this.connection = connection; }