refactoring

redisson/src/main/java/org/redisson/RedissonReliableTopic.java

@@ -46,7 +46,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
  * @author Nikita Koksharov
  *
  */
-public class RedissonReliableTopic extends RedissonExpirable implements RReliableTopic {
+public final class RedissonReliableTopic extends RedissonExpirable implements RReliableTopic {
 
     private static final Logger log = LoggerFactory.getLogger(RedissonReliableTopic.class);
 
@@ -77,7 +77,7 @@ public class RedissonReliableTopic extends RedissonExpirable implements RReliabl
     private final AtomicBoolean subscribed = new AtomicBoolean();
     private final String timeoutName;
 
-    public RedissonReliableTopic(Codec codec, CommandAsyncExecutor commandExecutor, String name, String subscriberId) {
+    RedissonReliableTopic(Codec codec, CommandAsyncExecutor commandExecutor, String name, String subscriberId) {
         super(codec, commandExecutor, name);
         stream = new RedissonStream<>(new CompositeCodec(StringCodec.INSTANCE, codec), commandExecutor, name);
         if (subscriberId == null) {
@@ -87,7 +87,7 @@ public class RedissonReliableTopic extends RedissonExpirable implements RReliabl
         this.timeoutName = getTimeout(getRawName());
     }
 
-    public RedissonReliableTopic(CommandAsyncExecutor commandExecutor, String name, String subscriberId) {
+    RedissonReliableTopic(CommandAsyncExecutor commandExecutor, String name, String subscriberId) {
         this(commandExecutor.getServiceManager().getCfg().getCodec(), commandExecutor, name, subscriberId);
     }