Merge branch 'master' of github.com:redisson/redisson

redisson/src/main/java/org/redisson/remote/BaseRemoteProxy.java

@@ -67,12 +67,7 @@ public abstract class BaseRemoteProxy {
     private final Map<Class<?>, String> requestQueueNameCache = new ConcurrentHashMap<>();
     
     public String getRequestQueueName(Class<?> remoteInterface) {
-        String str = requestQueueNameCache.get(remoteInterface);
-        if (str == null) {
-            str = "{" + name + ":" + remoteInterface.getName() + "}";
-            requestQueueNameCache.put(remoteInterface, str);
-        }
-        return str;
+        return requestQueueNameCache.computeIfAbsent(remoteInterface, k -> "{" + name + ":" + k.getName() + "}");
     }
     
     protected RFuture<RemoteServiceAck> tryPollAckAgainAsync(RemoteInvocationOptions optionsCopy,

redisson/src/main/java/org/redisson/remote/BaseRemoteService.java

@@ -92,12 +92,7 @@ public abstract class BaseRemoteService {
 
 
     public String getRequestQueueName(Class<?> remoteInterface) {
-        String str = requestQueueNameCache.get(remoteInterface);
-        if (str == null) {
-            str = "{" + name + ":" + remoteInterface.getName() + "}";
-            requestQueueNameCache.put(remoteInterface, str);
-        }
-        return str;
+        return requestQueueNameCache.computeIfAbsent(remoteInterface, k -> "{" + name + ":" + k.getName() + "}");
     }
 
     protected ByteBuf encode(Object obj) {