diff --git a/redisson/src/main/java/org/redisson/CronSchedule.java b/redisson/src/main/java/org/redisson/CronSchedule.java
index 96f138ce4..448e23e7f 100644
--- a/redisson/src/main/java/org/redisson/CronSchedule.java
+++ b/redisson/src/main/java/org/redisson/CronSchedule.java
@@ -39,8 +39,8 @@ public class CronSchedule {
/**
* Creates cron expression object with defined expression string
*
- * @param expression
- * @return
+ * @param expression of cron
+ * @return object
* @throws IllegalArgumentException
* wrapping a ParseException if the expression is invalid
*/
@@ -52,9 +52,9 @@ public class CronSchedule {
* Creates cron expression which schedule task execution
* every day at the given time
*
- * @param hour
- * @param minute
- * @return
+ * @param hour of schedule
+ * @param minute of schedule
+ * @return object
* @throws IllegalArgumentException
* wrapping a ParseException if the expression is invalid
*/
@@ -68,18 +68,10 @@ public class CronSchedule {
* every given days of the week at the given time.
* Use Calendar object constants to define day.
*
- * @see Calendar#SUNDAY
- * @see Calendar#MONDAY
- * @see Calendar#TUESDAY
- * @see Calendar#WEDNESDAY
- * @see Calendar#THURSDAY
- * @see Calendar#FRIDAY
- * @see Calendar#SATURDAY
- *
- * @param hour
- * @param minute
+ * @param hour of schedule
+ * @param minute of schedule
* @param daysOfWeek - Calendar object constants
- * @return
+ * @return object
*/
public static CronSchedule weeklyOnDayAndHourAndMinute(int hour, int minute, Integer... daysOfWeek) {
if (daysOfWeek == null || daysOfWeek.length == 0) {
@@ -98,10 +90,10 @@ public class CronSchedule {
* Creates cron expression which schedule task execution
* every given day of the month at the given time
*
- * @param hour
- * @param minute
- * @param daysOfWeek
- * @return
+ * @param hour of schedule
+ * @param minute of schedule
+ * @param dayOfMonth of schedule
+ * @return object
*/
public static CronSchedule monthlyOnDayAndHourAndMinute(int dayOfMonth, int hour, int minute) {
String expression = String.format("0 %d %d %d * ?", minute, hour, dayOfMonth);
diff --git a/redisson/src/main/java/org/redisson/PubSubMessageListener.java b/redisson/src/main/java/org/redisson/PubSubMessageListener.java
index 3d205fa9e..412be84bf 100644
--- a/redisson/src/main/java/org/redisson/PubSubMessageListener.java
+++ b/redisson/src/main/java/org/redisson/PubSubMessageListener.java
@@ -23,8 +23,7 @@ import org.redisson.client.protocol.pubsub.PubSubType;
*
* @author Nikita Koksharov
*
- * @param
- * @param
+ * @param value
*/
public class PubSubMessageListener implements RedisPubSubListener
*
- *
If eviction is not required then it's better to use {@link org.redisson.reactive.RedissonSet}.
+ *
If eviction is not required then it's better to use {@link org.redisson.api.RSet}.
*
* @author Nikita Koksharov
*
- * @param key
* @param value
*/
public interface RSetCache extends Set, RExpirable, RSetCacheAsync {
@@ -42,11 +41,10 @@ public interface RSetCache extends Set, RExpirable, RSetCacheAsync {
* Stores value with specified time to live.
* Value expires after specified time to live.
*
- * @param key
- * @param value
+ * @param value to add
* @param ttl - time to live for key\value entry.
* If 0 then stores infinitely.
- * @param unit
+ * @param unit - time unit
* @return true if value has been added. false
* if value already been in collection.
*/
@@ -57,6 +55,7 @@ public interface RSetCache extends Set, RExpirable, RSetCacheAsync {
* This number can reflects expired elements too
* due to non realtime cleanup process.
*
+ * @return size of set
*/
@Override
int size();
@@ -64,7 +63,7 @@ public interface RSetCache extends Set, RExpirable, RSetCacheAsync {
/**
* Read all elements at once
*
- * @return
+ * @return values
*/
Set readAll();
diff --git a/redisson/src/main/java/org/redisson/api/RSetCacheAsync.java b/redisson/src/main/java/org/redisson/api/RSetCacheAsync.java
index 31cea9a8e..9736f2cdb 100644
--- a/redisson/src/main/java/org/redisson/api/RSetCacheAsync.java
+++ b/redisson/src/main/java/org/redisson/api/RSetCacheAsync.java
@@ -31,11 +31,10 @@ public interface RSetCacheAsync extends RCollectionAsync {
* Stores value with specified time to live.
* Value expires after specified time to live.
*
- * @param key
- * @param value
+ * @param value to add
* @param ttl - time to live for key\value entry.
* If 0 then stores infinitely.
- * @param unit
+ * @param unit - time unit
* @return true if value has been added. false
* if value already been in collection.
*/
@@ -46,6 +45,7 @@ public interface RSetCacheAsync extends RCollectionAsync {
* This number can reflects expired elements too
* due to non realtime cleanup process.
*
+ * @return size of set
*/
@Override
RFuture sizeAsync();
@@ -53,7 +53,7 @@ public interface RSetCacheAsync extends RCollectionAsync {
/**
* Read all elements at once
*
- * @return
+ * @return values
*/
RFuture> readAllAsync();
diff --git a/redisson/src/main/java/org/redisson/api/RSetReactive.java b/redisson/src/main/java/org/redisson/api/RSetReactive.java
index b5b91a9c6..02297e0cb 100644
--- a/redisson/src/main/java/org/redisson/api/RSetReactive.java
+++ b/redisson/src/main/java/org/redisson/api/RSetReactive.java
@@ -32,7 +32,7 @@ public interface RSetReactive extends RCollectionReactive {
* Removes and returns random element from set
* in async mode
*
- * @return
+ * @return value
*/
Publisher removeRandom();
@@ -40,7 +40,7 @@ public interface RSetReactive extends RCollectionReactive {
* Returns random element from set
* in async mode
*
- * @return
+ * @return value
*/
Publisher random();
@@ -58,8 +58,8 @@ public interface RSetReactive extends RCollectionReactive {
* Union sets specified by name and write to current set.
* If current set already exists, it is overwritten.
*
- * @param names
- * @return
+ * @param names - name of sets
+ * @return size of union
*/
Publisher union(String... names);
@@ -67,8 +67,8 @@ public interface RSetReactive extends RCollectionReactive {
* Union sets specified by name with current set.
* Without current set state change.
*
- * @param names
- * @return
+ * @param names - name of sets
+ * @return size of union
*/
Publisher> readUnion(String... names);
@@ -76,8 +76,8 @@ public interface RSetReactive extends RCollectionReactive {
* Diff sets specified by name and write to current set.
* If current set already exists, it is overwritten.
*
- * @param names
- * @return
+ * @param names - name of sets
+ * @return size of diff
*/
Publisher diff(String... names);
@@ -85,8 +85,8 @@ public interface RSetReactive extends RCollectionReactive {
* Intersection sets specified by name and write to current set.
* If current set already exists, it is overwritten.
*
- * @param names
- * @return
+ * @param names - name of sets
+ * @return size of intersection
*/
Publisher intersection(String... names);
@@ -94,8 +94,8 @@ public interface RSetReactive extends RCollectionReactive {
* Intersection sets specified by name with current set.
* Without current set state change.
*
- * @param names
- * @return
+ * @param names - name of sets
+ * @return values
*/
Publisher> readIntersection(String... names);
diff --git a/redisson/src/main/java/org/redisson/api/RSortedSet.java b/redisson/src/main/java/org/redisson/api/RSortedSet.java
index abf3655fe..dc72886d6 100644
--- a/redisson/src/main/java/org/redisson/api/RSortedSet.java
+++ b/redisson/src/main/java/org/redisson/api/RSortedSet.java
@@ -27,7 +27,7 @@ public interface RSortedSet extends SortedSet, RObject {
/**
* Sets new comparator only if current set is empty
*
- * @param comparator
+ * @param comparator for values
* @return true if new comparator setted
* false otherwise
*/
diff --git a/redisson/src/main/java/org/redisson/api/RTopic.java b/redisson/src/main/java/org/redisson/api/RTopic.java
index cb709df82..5cc2e2cec 100644
--- a/redisson/src/main/java/org/redisson/api/RTopic.java
+++ b/redisson/src/main/java/org/redisson/api/RTopic.java
@@ -32,14 +32,14 @@ public interface RTopic extends RTopicAsync {
/**
* Get topic channel names
*
- * @return
+ * @return channel names
*/
List getChannelNames();
/**
* Publish the message to all subscribers of this topic
*
- * @param message
+ * @param message to send
* @return the number of clients that received the message
*/
long publish(M message);
@@ -49,7 +49,7 @@ public interface RTopic extends RTopicAsync {
* MessageListener.onMessage is called when any message
* is published on this topic.
*
- * @param listener
+ * @param listener for messages
* @return locally unique listener id
* @see org.redisson.api.listener.MessageListener
*/
@@ -58,8 +58,8 @@ public interface RTopic extends RTopicAsync {
/**
* Subscribes to status changes of this topic
*
- * @param listener
- * @return
+ * @param listener for messages
+ * @return listener id
* @see org.redisson.api.listener.StatusListener
*/
int addListener(StatusListener listener);
@@ -67,7 +67,7 @@ public interface RTopic extends RTopicAsync {
/**
* Removes the listener by id for listening this topic
*
- * @param listenerId
+ * @param listenerId - listener id
*/
void removeListener(int listenerId);
diff --git a/redisson/src/main/java/org/redisson/api/RTopicAsync.java b/redisson/src/main/java/org/redisson/api/RTopicAsync.java
index 6229cad53..b676bb807 100644
--- a/redisson/src/main/java/org/redisson/api/RTopicAsync.java
+++ b/redisson/src/main/java/org/redisson/api/RTopicAsync.java
@@ -27,7 +27,7 @@ public interface RTopicAsync {
/**
* Publish the message to all subscribers of this topic asynchronously
*
- * @param message
+ * @param message to send
* @return the RFuture object with number of clients that received the message
*/
RFuture publishAsync(M message);
diff --git a/redisson/src/main/java/org/redisson/api/RTopicReactive.java b/redisson/src/main/java/org/redisson/api/RTopicReactive.java
index fd1433f7b..52b5432f3 100644
--- a/redisson/src/main/java/org/redisson/api/RTopicReactive.java
+++ b/redisson/src/main/java/org/redisson/api/RTopicReactive.java
@@ -35,7 +35,7 @@ public interface RTopicReactive {
/**
* Publish the message to all subscribers of this topic asynchronously
*
- * @param message
+ * @param message to send
* @return the Future object with number of clients that received the message
*/
Publisher publish(M message);
diff --git a/redisson/src/main/java/org/redisson/api/listener/MessageListener.java b/redisson/src/main/java/org/redisson/api/listener/MessageListener.java
index 9d28e65dc..9b4a0c529 100644
--- a/redisson/src/main/java/org/redisson/api/listener/MessageListener.java
+++ b/redisson/src/main/java/org/redisson/api/listener/MessageListener.java
@@ -31,6 +31,7 @@ public interface MessageListener extends EventListener {
/**
* Invokes on every message in topic
*
+ * @param channel of topic
* @param msg topic message
*/
void onMessage(String channel, M msg);
diff --git a/redisson/src/main/java/org/redisson/api/listener/PatternMessageListener.java b/redisson/src/main/java/org/redisson/api/listener/PatternMessageListener.java
index 8ace2607d..ac4d8797a 100644
--- a/redisson/src/main/java/org/redisson/api/listener/PatternMessageListener.java
+++ b/redisson/src/main/java/org/redisson/api/listener/PatternMessageListener.java
@@ -31,6 +31,8 @@ public interface PatternMessageListener extends EventListener {
/**
* Invokes on every message in topic
*
+ * @param pattern of channel name
+ * @param channel of topic
* @param msg topic message
*/
void onMessage(String pattern, String channel, M msg);
diff --git a/redisson/src/main/java/org/redisson/api/listener/StatusListener.java b/redisson/src/main/java/org/redisson/api/listener/StatusListener.java
index 138c1abca..77088c38f 100644
--- a/redisson/src/main/java/org/redisson/api/listener/StatusListener.java
+++ b/redisson/src/main/java/org/redisson/api/listener/StatusListener.java
@@ -30,14 +30,14 @@ public interface StatusListener extends EventListener {
* Executes then Redisson successfully subscribed to channel.
* Invoked during re-connection
*
- * @param channel
+ * @param channel to subscribe
*/
void onSubscribe(String channel);
/**
* Executes then Redisson successfully unsubscribed from channel.
*
- * @param channel
+ * @param channel to unsubscribe
*/
void onUnsubscribe(String channel);
diff --git a/redisson/src/main/java/org/redisson/client/RedisConnection.java b/redisson/src/main/java/org/redisson/client/RedisConnection.java
index 193450496..0d5b37070 100644
--- a/redisson/src/main/java/org/redisson/client/RedisConnection.java
+++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java
@@ -223,7 +223,8 @@ public class RedisConnection implements RedisCommands {
/**
* Access to Netty channel.
* This method is provided to use in debug info only.
- *
+ *
+ * @return channel
*/
public Channel getChannel() {
return channel;
diff --git a/redisson/src/main/java/org/redisson/client/codec/Codec.java b/redisson/src/main/java/org/redisson/client/codec/Codec.java
index cfb90d08c..c7813c284 100644
--- a/redisson/src/main/java/org/redisson/client/codec/Codec.java
+++ b/redisson/src/main/java/org/redisson/client/codec/Codec.java
@@ -29,42 +29,42 @@ public interface Codec {
/**
* Returns object decoder used for hash map values in HMAP Redis structure
*
- * @return
+ * @return decoder
*/
Decoder