diff --git a/src/main/java/org/springframework/data/redis/connection/FutureResult.java b/src/main/java/org/springframework/data/redis/connection/FutureResult.java index c3e78689d..431ae5b28 100644 --- a/src/main/java/org/springframework/data/redis/connection/FutureResult.java +++ b/src/main/java/org/springframework/data/redis/connection/FutureResult.java @@ -75,8 +75,6 @@ abstract public class FutureResult { /** * Indicates if this result is the status of an operation. Typically status results will be discarded on conversion. - * - * @return true if this is a status result (i.e. OK) */ public void setStatus(boolean status) { this.status = status; diff --git a/src/main/java/org/springframework/data/redis/connection/RedisConnectionCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisConnectionCommands.java index 42b47fc8d..e20f869c4 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisConnectionCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisConnectionCommands.java @@ -25,16 +25,18 @@ public interface RedisConnectionCommands { /** * Select the DB with given positive {@code dbIndex}. + *

+ * See http://redis.io/commands/select * - * @see http://redis.io/commands/select * @param dbIndex */ void select(int dbIndex); /** * Returns {@code message} via server roundtrip. + *

+ * See http://redis.io/commands/echo * - * @see http://redis.io/commands/echo * @param message * @return */ @@ -42,8 +44,9 @@ public interface RedisConnectionCommands { /** * Test connection. + *

+ * See http://redis.io/commands/ping * - * @see http://redis.io/commands/ping * @return Server response message - usually {@literal PONG}. */ String ping(); diff --git a/src/main/java/org/springframework/data/redis/connection/RedisPipelineException.java b/src/main/java/org/springframework/data/redis/connection/RedisPipelineException.java index bf51783cd..324b79e83 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisPipelineException.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisPipelineException.java @@ -24,7 +24,7 @@ import org.springframework.dao.InvalidDataAccessResourceUsageException; /** * Exception thrown when executing/closing a pipeline that contains one or multiple invalid/incorrect statements. The * exception might also contain the pipeline result (if the driver returns it), allowing for analysis and tracing. - *

+ *

* Typically, the first exception returned by the pipeline is used as the cause of this exception for easier * debugging. * diff --git a/src/main/java/org/springframework/data/redis/connection/RedisPubSubCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisPubSubCommands.java index ca63e1591..87da53380 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisPubSubCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisPubSubCommands.java @@ -48,7 +48,7 @@ public interface RedisPubSubCommands { /** * Subscribes the connection to the given channels. Once subscribed, a connection enters listening mode and can only * subscribe to other channels or unsubscribe. No other commands are accepted until the connection is unsubscribed. - *

+ *

* Note that this operation is blocking and the current thread starts waiting for new messages immediately. * * @param listener message listener @@ -60,7 +60,7 @@ public interface RedisPubSubCommands { * Subscribes the connection to all channels matching the given patterns. Once subscribed, a connection enters * listening mode and can only subscribe to other channels or unsubscribe. No other commands are accepted until the * connection is unsubscribed. - *

+ *

* Note that this operation is blocking and the current thread starts waiting for new messages immediately. * * @param listener message listener diff --git a/src/main/java/org/springframework/data/redis/connection/RedisScriptingCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisScriptingCommands.java index 62d736ae4..0f22e6217 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisScriptingCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisScriptingCommands.java @@ -28,23 +28,24 @@ public interface RedisScriptingCommands { /** * Flush lua script cache. - * - * @see http://redis.io/commands/script-flush + *

+ * See http://redis.io/commands/script-flush */ void scriptFlush(); /** * Kill current lua script execution. - * - * @see http://redis.io/commands/script-kill + *

+ * See http://redis.io/commands/script-kill */ void scriptKill(); /** - * Load lua script into scripts cache, without executing it.
+ * Load lua script into scripts cache, without executing it.
* Execute the script by calling {@link #evalSha(String, ReturnType, int, byte[])}. + *

+ * See http://redis.io/commands/script-load * - * @see http://redis.io/commands/script-load * @param script * @return */ @@ -52,8 +53,9 @@ public interface RedisScriptingCommands { /** * Check if given {@code scriptShas} exist in script cache. + *

+ * See http://redis.io/commands/script-exits * - * @see http://redis.io/commands/script-exits * @param scriptShas * @return one entry per given scriptSha in returned list. */ @@ -61,8 +63,9 @@ public interface RedisScriptingCommands { /** * Evaluate given {@code script}. + *

+ * See http://redis.io/commands/eval * - * @see http://redis.io/commands/eval * @param script * @param returnType * @param numKeys @@ -73,9 +76,10 @@ public interface RedisScriptingCommands { /** * Evaluate given {@code scriptSha}. + *

+ * See http://redis.io/commands/evalsha * - * @see http://redis.io/commands/evalsha - * @param script + * @param scriptSha * @param returnType * @param numKeys * @param keysAndArgs @@ -85,9 +89,10 @@ public interface RedisScriptingCommands { /** * Evaluate given {@code scriptSha}. + *

+ * See http://redis.io/commands/evalsha * - * @see http://redis.io/commands/evalsha - * @param script + * @param scriptSha * @param returnType * @param numKeys * @param keysAndArgs diff --git a/src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java index 2416bc49b..c24d595fd 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java @@ -35,8 +35,9 @@ public interface RedisServerCommands { /** * Start an {@literal Append Only File} rewrite process on server. + *

+ * See http://redis.io/commands/bgrewriteaof * - * @see http://redis.io/commands/bgrewriteaof * @deprecated As of 1.3, use {@link #bgReWriteAof}. */ @Deprecated @@ -44,53 +45,56 @@ public interface RedisServerCommands { /** * Start an {@literal Append Only File} rewrite process on server. + *

+ * See http://redis.io/commands/bgrewriteaof * - * @see http://redis.io/commands/bgrewriteaof * @since 1.3 */ void bgReWriteAof(); /** * Start background saving of db on server. - * - * @see http://redis.io/commands/bgsave + *

+ * See http://redis.io/commands/bgsave */ void bgSave(); /** * Get time of last {@link #bgSave()} operation in seconds. + *

+ * See http://redis.io/commands/lastsave * - * @see http://redis.io/commands/lastsave * @return */ Long lastSave(); /** * Synchronous save current db snapshot on server. - * - * @see http://redis.io/commands/save + *

+ * See http://redis.io/commands/save */ void save(); /** * Get the total number of available keys in currently selected database. + *

+ * See http://redis.io/commands/dbsize * - * @see http://redis.io/commands/dbsize * @return */ Long dbSize(); /** * Delete all keys of the currently selected database. - * - * @see http://redis.io/commands/flushdb + *

+ * See http://redis.io/commands/flushdb */ void flushDb(); /** * Delete all all keys from all databases. - * - * @see http://redis.io/commands/flushall + *

+ * See http://redis.io/commands/flushall */ void flushAll(); @@ -101,58 +105,63 @@ public interface RedisServerCommands { *

  • cpu utilization
  • *
  • replication
  • * + *

    + * See http://redis.io/commands/info * - * @see http://redis.io/commands/info * @return */ Properties info(); /** * Load server information for given {@code selection}. + *

    + * See http://redis.io/commands/info * - * @see http://redis.io/commands/info * @return */ Properties info(String section); /** * Shutdown server. - * - * @see http://redis.io/commands/shutdown + *

    + * See http://redis.io/commands/shutdown */ void shutdown(); /** * Shutdown server. + *

    + * See http://redis.io/commands/shutdown * - * @see http://redis.io/commands/shutdown * @since 1.3 */ void shutdown(ShutdownOption option); /** * Load configuration parameters for given {@code pattern} from server. + *

    + * See http://redis.io/commands/config-get * - * @see http://redis.io/commands/config-get * @param pattern * @return */ List getConfig(String pattern); /** - * Set server configuration for {@code key} to {@code value}. + * Set server configuration for {@code param} to {@code value}. + *

    + * See http://redis.io/commands/config-set * - * @see http://redis.io/commands/config-set * @param param * @param value */ void setConfig(String param, String value); /** - * Reset statistic counters on server.
    + * Reset statistic counters on server.
    * Counters can be retrieved using {@link #info()}. - * - * @see http://redis.io/commands/config-resetstat + *

    + * See http://redis.io/commands/config-resetstat */ void resetConfigStats(); @@ -165,7 +174,7 @@ public interface RedisServerCommands { Long time(); /** - * <<<<<<< HEAD Closes a given client connection identified by {@literal ip:port}. + * Closes a given client connection identified by {@literal host:port}. * * @param host of connection to close. * @param port of connection to close @@ -176,14 +185,16 @@ public interface RedisServerCommands { /** * Assign given name to current connection. * + * @param name * @since 1.3 */ void setClientName(byte[] name); /** * Returns the name of the current connection. + *

    + * See http://redis.io/commands/client-getname * - * @see http://redis.io/commands/client-getname * @return * @since 1.3 */ @@ -191,28 +202,31 @@ public interface RedisServerCommands { /** * Request information and statistics about connected clients. + *

    + * See http://redis.io/commands/client-list * * @return {@link List} of {@link RedisClientInfo} objects. * @since 1.3 - * @see http://redis.io/commands/client-list */ List getClientList(); /** * Change redis replication setting to new master. + *

    + * See http://redis.io/commands/slaveof * * @param host * @param port * @since 1.3 - * @see http://redis.io/commands/slaveof */ void slaveOf(String host, int port); /** * Change server into master. + *

    + * See http://redis.io/commands/slaveof * * @since 1.3 - * @see http://redis.io/commands/slaveof */ void slaveOfNoOne(); } diff --git a/src/main/java/org/springframework/data/redis/connection/RedisSetCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisSetCommands.java index 873b45f23..7768e4dd5 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisSetCommands.java @@ -62,7 +62,7 @@ public interface RedisSetCommands { byte[] sPop(byte[] key); /** - * Move {@code value} from {@code srcKey} to {@destKey} + * Move {@code value} from {@code srcKey} to {@code destKey} *

    * See http://redis.io/commands/smove * diff --git a/src/main/java/org/springframework/data/redis/connection/RedisTxCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisTxCommands.java index 293f3a70d..2426d5284 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisTxCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisTxCommands.java @@ -26,42 +26,43 @@ import java.util.List; public interface RedisTxCommands { /** - * Mark the start of a transaction block.
    + * Mark the start of a transaction block.
    * Commands will be queued and can then be executed by calling {@link #exec()} or rolled back using {@link #discard()} - * . - * - * @see http://redis.io/commands/multi + *

    + * See http://redis.io/commands/multi */ void multi(); /** - * Executes all queued commands in a transaction started with {@link #multi()}.
    + * Executes all queued commands in a transaction started with {@link #multi()}.
    * If used along with {@link #watch(byte[])} the operation will fail if any of watched keys has been modified. + *

    + * See http://redis.io/commands/exec * - * @see http://redis.io/commands/exec * @return List of replies for each executed command. */ List exec(); /** * Discard all commands issued after {@link #multi()}. - * - * @see http://redis.io/commands/discard + *

    + * See http://redis.io/commands/discard */ void discard(); /** * Watch given {@code keys} for modifications during transaction started with {@link #multi()}. + *

    + * See http://redis.io/commands/watch * - * @see http://redis.io/commands/watch * @param keys */ void watch(byte[]... keys); /** * Flushes all the previously {@link #watch(byte[])} keys. - * - * @see http://redis.io/commands/unwatch + *

    + * See http://redis.io/commands/unwatch */ void unwatch(); } diff --git a/src/main/java/org/springframework/data/redis/connection/RedisZSetCommands.java b/src/main/java/org/springframework/data/redis/connection/RedisZSetCommands.java index 5ea8b75ef..438632145 100644 --- a/src/main/java/org/springframework/data/redis/connection/RedisZSetCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/RedisZSetCommands.java @@ -194,7 +194,7 @@ public interface RedisZSetCommands { Set zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count); /** - * Get elements in range from {@code begin} to {@code end} from sorted set ordered high -> low. + * Get elements in range from {@code begin} to {@code end} from sorted set ordered from high to low. *

    * See http://redis.io/commands/zrevrange * @@ -206,7 +206,7 @@ public interface RedisZSetCommands { Set zRevRange(byte[] key, long begin, long end); /** - * Get set of {@link Tuple}s in range from {@code begin} to {@code end} from sorted set ordered high -> low. + * Get set of {@link Tuple}s in range from {@code begin} to {@code end} from sorted set ordered from high to low. *

    * See http://redis.io/commands/zrevrange * @@ -218,7 +218,7 @@ public interface RedisZSetCommands { Set zRevRangeWithScores(byte[] key, long begin, long end); /** - * Get elements where score is between {@code min} and {@code max} from sorted set ordered high -> low. + * Get elements where score is between {@code min} and {@code max} from sorted set ordered from high to low. *

    * See http://redis.io/commands/zrevrange * @@ -230,7 +230,8 @@ public interface RedisZSetCommands { Set zRevRangeByScore(byte[] key, double min, double max); /** - * Get set of {@link Tuple} where score is between {@code min} and {@code max} from sorted set ordered high -> low. + * Get set of {@link Tuple} where score is between {@code min} and {@code max} from sorted set ordered from high to + * low. *

    * See http://redis.io/commands/zrevrange * diff --git a/src/main/java/org/springframework/data/redis/connection/ReturnType.java b/src/main/java/org/springframework/data/redis/connection/ReturnType.java index 820c3c55d..cf7162624 100644 --- a/src/main/java/org/springframework/data/redis/connection/ReturnType.java +++ b/src/main/java/org/springframework/data/redis/connection/ReturnType.java @@ -25,19 +25,29 @@ import java.util.List; */ public enum ReturnType { - /** Returned as Boolean **/ + /** + * Returned as Boolean + */ BOOLEAN, - /** Returned as Long **/ + /** + * Returned as {@link Long} + */ INTEGER, - /** Returned as List **/ + /** + * Returned as {@link List} + */ MULTI, - /** Returned as byte[] **/ + /** + * Returned as {@literal byte[]} + */ STATUS, - /** Returned as byte[] **/ + /** + * Returned as {@literal byte[]} + */ VALUE; public static ReturnType fromJavaType(Class javaType) { diff --git a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java index a69410be8..ad3ebf2e8 100644 --- a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java @@ -101,10 +101,11 @@ public interface StringRedisConnection extends RedisConnection { /** * Set the {@code value} and expiration in {@code milliseconds} for {@code key}. + *

    + * See http://redis.io/commands/psetex * - * @see http://redis.io/commands/psetex * @param key - * @param seconds + * @param milliseconds * @param value * @since 1.3 */ @@ -311,7 +312,7 @@ public interface StringRedisConnection extends RedisConnection { * * @param name * @see #setClientName(byte[]) - * @sice 1.3 + * @since 1.3 */ void setClientName(String name); diff --git a/src/main/java/org/springframework/data/redis/connection/package-info.java b/src/main/java/org/springframework/data/redis/connection/package-info.java index 4107c3fb3..fa07c3cf8 100644 --- a/src/main/java/org/springframework/data/redis/connection/package-info.java +++ b/src/main/java/org/springframework/data/redis/connection/package-info.java @@ -2,7 +2,7 @@ * Connection package providing low-level abstractions for interacting with * the various Redis 'drivers'/libraries. * - *

    Performs exception translation between the underlying library exceptions to Spring's DAO hierarchy. + *

    Performs exception translation between the underlying library exceptions to Spring's DAO hierarchy. */ package org.springframework.data.redis.connection; diff --git a/src/main/java/org/springframework/data/redis/core/BoundHashOperations.java b/src/main/java/org/springframework/data/redis/core/BoundHashOperations.java index ec0028e4f..ccc23dd12 100644 --- a/src/main/java/org/springframework/data/redis/core/BoundHashOperations.java +++ b/src/main/java/org/springframework/data/redis/core/BoundHashOperations.java @@ -57,9 +57,9 @@ public interface BoundHashOperations extends BoundKeyOperations { Map entries(); /** - * @since 1.4 - * @param key + * @param options * @return + * @since 1.4 */ Cursor> scan(ScanOptions options); } diff --git a/src/main/java/org/springframework/data/redis/core/BoundKeyOperations.java b/src/main/java/org/springframework/data/redis/core/BoundKeyOperations.java index abd4326f8..afe884984 100644 --- a/src/main/java/org/springframework/data/redis/core/BoundKeyOperations.java +++ b/src/main/java/org/springframework/data/redis/core/BoundKeyOperations.java @@ -25,7 +25,7 @@ import org.springframework.data.redis.connection.DataType; *

    * As the rest of the APIs, if the underlying connection is pipelined or queued/in multi mode, all methods will return * null. - *

    + *

    * * @author Costin Leau * @author Christoph Strobl @@ -78,7 +78,7 @@ public interface BoundKeyOperations { Boolean persist(); /** - * Renames the key.
    + * Renames the key.
    * Note: The new name for empty collections will be propagated on add of first element. * * @param newKey new key diff --git a/src/main/java/org/springframework/data/redis/core/BulkMapper.java b/src/main/java/org/springframework/data/redis/core/BulkMapper.java index acf04b6ee..0f7c8f0ab 100644 --- a/src/main/java/org/springframework/data/redis/core/BulkMapper.java +++ b/src/main/java/org/springframework/data/redis/core/BulkMapper.java @@ -20,7 +20,7 @@ import java.util.List; /** * Mapper translating Redis bulk value responses (typically returned by a sort query) to actual objects. Implementations * of this interface do not have to worry about exception or connection handling. - *

    + *

    * Typically used by {@link RedisTemplate} sort methods. * * @author Costin Leau diff --git a/src/main/java/org/springframework/data/redis/core/Cursor.java b/src/main/java/org/springframework/data/redis/core/Cursor.java index 12c3f3b2a..cb00064be 100644 --- a/src/main/java/org/springframework/data/redis/core/Cursor.java +++ b/src/main/java/org/springframework/data/redis/core/Cursor.java @@ -26,7 +26,7 @@ import java.util.Iterator; public interface Cursor extends Iterator, Closeable { /** - * Get the reference cursor.
    + * Get the reference cursor.
    * NOTE: the id might change while iterating items. * * @return diff --git a/src/main/java/org/springframework/data/redis/core/HyperLogLogOperations.java b/src/main/java/org/springframework/data/redis/core/HyperLogLogOperations.java index 54ef650e7..b694e005c 100644 --- a/src/main/java/org/springframework/data/redis/core/HyperLogLogOperations.java +++ b/src/main/java/org/springframework/data/redis/core/HyperLogLogOperations.java @@ -33,7 +33,7 @@ public interface HyperLogLogOperations { /** * Gets the current number of elements within the {@literal key}. * - * @param keys must not be {@literal null) or {@literal empty}. + * @param keys must not be {@literal null} or {@literal empty}. * @return */ Long size(K... keys); @@ -42,7 +42,7 @@ public interface HyperLogLogOperations { * Merges all values of given {@literal sourceKeys} into {@literal destination} key. * * @param destination key of HyperLogLog to move source keys into. - * @param sourceKeys must not be {@literal null) or {@literal empty}. + * @param sourceKeys must not be {@literal null} or {@literal empty}. */ Long union(K destination, K... sourceKeys); diff --git a/src/main/java/org/springframework/data/redis/core/RedisCommand.java b/src/main/java/org/springframework/data/redis/core/RedisCommand.java index 4115bc8c5..061b47e56 100644 --- a/src/main/java/org/springframework/data/redis/core/RedisCommand.java +++ b/src/main/java/org/springframework/data/redis/core/RedisCommand.java @@ -324,7 +324,7 @@ public enum RedisCommand { * Validates given argument count against expected ones. * * @param nrArguments - * @throws {@link IllegalArgumentException} in case argument count does not match expected. + * @exception IllegalArgumentException in case argument count does not match expected. */ public void validateArgumentCount(int nrArguments) { diff --git a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java index f449a680a..a5bf4a05d 100644 --- a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java +++ b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java @@ -15,7 +15,12 @@ */ package org.springframework.data.redis.listener; -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.List; +import java.util.Map; +import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.Executor; @@ -30,7 +35,12 @@ import org.springframework.context.SmartLifecycle; import org.springframework.core.task.SimpleAsyncTaskExecutor; import org.springframework.core.task.TaskExecutor; import org.springframework.data.redis.RedisConnectionFailureException; -import org.springframework.data.redis.connection.*; +import org.springframework.data.redis.connection.ConnectionUtils; +import org.springframework.data.redis.connection.Message; +import org.springframework.data.redis.connection.MessageListener; +import org.springframework.data.redis.connection.RedisConnection; +import org.springframework.data.redis.connection.RedisConnectionFactory; +import org.springframework.data.redis.connection.Subscription; import org.springframework.data.redis.connection.util.ByteArrayWrapper; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; @@ -43,13 +53,13 @@ import org.springframework.util.ErrorHandler; /** * Container providing asynchronous behaviour for Redis message listeners. Handles the low level details of listening, * converting and message dispatching. - *

    + *

    * As oppose to the low level Redis (one connection per subscription), the container uses only one connection that is * 'multiplexed' for all registered listeners, the message dispatch being done through the task executor. - *

    + *

    * Note the container uses the connection in a lazy fashion (the connection is used only if at least one listener is * configured). - *

    + *

    * Adding and removing listeners at the same time has undefined results. It is strongly recommended to synchronize/order * these methods accordingly. * @@ -313,7 +323,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab * Sets the task execution used for subscribing to Redis channels. By default, if no executor is set, the * {@link #setTaskExecutor(Executor)} will be used. In some cases, this might be undersired as the listening to the * connection is a long running task. - *

    + *

    * Note: This implementation uses at most one long running thread (depending on whether there are any listeners * registered or not) and up to two threads during the initial registration. * @@ -343,7 +353,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab /** * Attaches the given listeners (and their topics) to the container. - *

    + *

    * Note: it's possible to call this method while the container is running forcing a reinitialization of the container. * Note however that this might cause some messages to be lost (while the container reinitializes) - hence calling * this method at runtime is considered advanced usage. @@ -380,7 +390,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab /** * Removes a message listener from the given topics. If the container is running, the listener stops receiving * (matching) messages as soon as possible. - *

    + *

    * Note that this method obeys the Redis (p)unsubscribe semantics - meaning an empty/null collection will remove * listener from all channels. Similarly a null listener will unsubscribe all listeners from the given topic. * @@ -394,7 +404,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab /** * Removes a message listener from the from the given topic. If the container is running, the listener stops receiving * (matching) messages as soon as possible. - *

    + *

    * Note that this method obeys the Redis (p)unsubscribe semantics - meaning an empty/null collection will remove * listener from all channels. Similarly a null listener will unsubscribe all listeners from the given topic. * diff --git a/src/main/java/org/springframework/data/redis/serializer/Jackson2JsonRedisSerializer.java b/src/main/java/org/springframework/data/redis/serializer/Jackson2JsonRedisSerializer.java index ecf6c9c95..c8b86c8ab 100644 --- a/src/main/java/org/springframework/data/redis/serializer/Jackson2JsonRedisSerializer.java +++ b/src/main/java/org/springframework/data/redis/serializer/Jackson2JsonRedisSerializer.java @@ -27,7 +27,7 @@ import com.fasterxml.jackson.databind.type.TypeFactory; /** * {@link RedisSerializer} that can read and write JSON using Jackson's and Jackson Databind {@link ObjectMapper}. + * href="https://github.com/FasterXML/jackson-databind">Jackson Databind {@link ObjectMapper}. *

    * This converter can be used to bind to typed beans, or untyped {@link java.util.HashMap HashMap} instances. * Note:Null objects are serialized as empty arrays and vice versa. @@ -55,7 +55,7 @@ public class Jackson2JsonRedisSerializer implements RedisSerializer { /** * Creates a new {@link Jackson2JsonRedisSerializer} for the given target {@link JavaType}. * - * @param type + * @param javaType */ public Jackson2JsonRedisSerializer(JavaType javaType) { this.javaType = javaType; diff --git a/src/main/java/org/springframework/data/redis/serializer/StringRedisSerializer.java b/src/main/java/org/springframework/data/redis/serializer/StringRedisSerializer.java index dea8d61b6..14a24562d 100644 --- a/src/main/java/org/springframework/data/redis/serializer/StringRedisSerializer.java +++ b/src/main/java/org/springframework/data/redis/serializer/StringRedisSerializer.java @@ -22,9 +22,9 @@ import org.springframework.util.Assert; /** * Simple String to byte[] (and back) serializer. Converts Strings into bytes and vice-versa using the specified charset * (by default UTF-8). - *

    + *

    * Useful when the interaction with the Redis happens mainly through Strings. - *

    + *

    * Does not perform any null conversion since empty strings are valid keys/values. * * @author Costin Leau