From 7d832dddf9b7aa21fb2c07c8e1dff5164a6cfe1f Mon Sep 17 00:00:00 2001 From: Nikita Date: Fri, 9 Mar 2018 20:05:27 +0300 Subject: [PATCH] comments added --- redisson/src/main/java/org/redisson/api/RBloomFilter.java | 5 +++++ .../java/org/redisson/client/BaseRedisPubSubListener.java | 5 +++++ .../main/java/org/redisson/client/RedisPubSubListener.java | 6 ++++++ .../main/java/org/redisson/client/SubscribeListener.java | 5 +++++ 4 files changed, 21 insertions(+) diff --git a/redisson/src/main/java/org/redisson/api/RBloomFilter.java b/redisson/src/main/java/org/redisson/api/RBloomFilter.java index 92dd1ae01..c7220cac8 100644 --- a/redisson/src/main/java/org/redisson/api/RBloomFilter.java +++ b/redisson/src/main/java/org/redisson/api/RBloomFilter.java @@ -44,6 +44,11 @@ public interface RBloomFilter extends RExpirable { double getFalseProbability(); + /** + * Returns number of bits in Redis memory required by this instance + * + * @return number of bits + */ long getSize(); int getHashIterations(); diff --git a/redisson/src/main/java/org/redisson/client/BaseRedisPubSubListener.java b/redisson/src/main/java/org/redisson/client/BaseRedisPubSubListener.java index b618cae1a..ffba58572 100644 --- a/redisson/src/main/java/org/redisson/client/BaseRedisPubSubListener.java +++ b/redisson/src/main/java/org/redisson/client/BaseRedisPubSubListener.java @@ -17,6 +17,11 @@ package org.redisson.client; import org.redisson.client.protocol.pubsub.PubSubType; +/** + * + * @author Nikita Koksharov + * + */ public class BaseRedisPubSubListener implements RedisPubSubListener { @Override diff --git a/redisson/src/main/java/org/redisson/client/RedisPubSubListener.java b/redisson/src/main/java/org/redisson/client/RedisPubSubListener.java index 5324bee81..ea13d3867 100644 --- a/redisson/src/main/java/org/redisson/client/RedisPubSubListener.java +++ b/redisson/src/main/java/org/redisson/client/RedisPubSubListener.java @@ -18,6 +18,12 @@ package org.redisson.client; import org.redisson.api.listener.MessageListener; import org.redisson.client.protocol.pubsub.PubSubType; +/** + * + * @author Nikita Koksharov + * + * @param value type + */ public interface RedisPubSubListener extends MessageListener { boolean onStatus(PubSubType type, String channel); diff --git a/redisson/src/main/java/org/redisson/client/SubscribeListener.java b/redisson/src/main/java/org/redisson/client/SubscribeListener.java index 2dc91d5ae..5eeecfeac 100644 --- a/redisson/src/main/java/org/redisson/client/SubscribeListener.java +++ b/redisson/src/main/java/org/redisson/client/SubscribeListener.java @@ -21,6 +21,11 @@ import io.netty.util.concurrent.Future; import io.netty.util.concurrent.ImmediateEventExecutor; import io.netty.util.concurrent.Promise; +/** + * + * @author Nikita Koksharov + * + */ public class SubscribeListener extends BaseRedisPubSubListener { Promise promise = ImmediateEventExecutor.INSTANCE.newPromise();