From b7da522b749b4660a0c2712bd20cce646a6f05fb Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 25 Nov 2016 17:03:54 +0300
Subject: [PATCH] Refactoring

---
 .../java/org/redisson/client/RedisConnection.java   |  4 ++++
 .../java/org/redisson/pubsub/AsyncSemaphore.java    | 13 +++++++++++++
 2 files changed, 17 insertions(+)

diff --git a/redisson/src/main/java/org/redisson/client/RedisConnection.java b/redisson/src/main/java/org/redisson/client/RedisConnection.java
index 44d2870c6..e0fe7c07c 100644
--- a/redisson/src/main/java/org/redisson/client/RedisConnection.java
+++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java
@@ -58,6 +58,10 @@ public class RedisConnection implements RedisCommands {
         updateChannel(channel);
         lastUsageTime = System.currentTimeMillis();
     }
+    
+    protected RedisConnection() {
+        redisClient = null;
+    }
 
     public static <C extends RedisConnection> C getFrom(Channel channel) {
         return (C) channel.attr(RedisConnection.CONNECTION).get();
diff --git a/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java b/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java
index 74ebcd055..d90c6c385 100644
--- a/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java
+++ b/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java
@@ -49,6 +49,19 @@ public class AsyncSemaphore {
         }
     }
     
+    public boolean tryAcquire() {
+        synchronized (this) {
+            if (counter == 0) {
+                return false;
+            }
+            if (counter > 0) {
+                counter--;
+                return true;
+            }
+            throw new IllegalStateException();
+        }
+    }
+    
     public void acquire(Runnable listener) {
         boolean run = false;