From 022b72cc06c415e60a70d92b5d2848dcba64198a Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 3 Jan 2014 13:42:49 +0400
Subject: [PATCH] retainAll fixed

---
 src/main/java/org/redisson/RedissonSet.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/redisson/RedissonSet.java b/src/main/java/org/redisson/RedissonSet.java
index 68c29d920..a920ba04c 100644
--- a/src/main/java/org/redisson/RedissonSet.java
+++ b/src/main/java/org/redisson/RedissonSet.java
@@ -75,10 +75,10 @@ public class RedissonSet<V> implements Set<V> {
 
     @Override
     public boolean retainAll(Collection<?> c) {
-        int changed = 0;
         RedisConnection<Object, Object> conn = redisson.connect();
         try {
             while (true) {
+                int changed = 0;
                 conn.watch(name);
                 Iterator<V> iterator = (Iterator<V>) conn.smembers(name).iterator();
                 conn.multi();