From bb8558e5d3108123ebd2fb512c9a3ea884671094 Mon Sep 17 00:00:00 2001 From: nite23 Date: Sun, 13 Jan 2013 22:57:40 +0100 Subject: [PATCH] Fix for #766 --- .../java/org/atmosphere/cache/AbstractBroadcasterCache.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/cpr/src/main/java/org/atmosphere/cache/AbstractBroadcasterCache.java b/modules/cpr/src/main/java/org/atmosphere/cache/AbstractBroadcasterCache.java index ccd8f31664e..247df5464da 100644 --- a/modules/cpr/src/main/java/org/atmosphere/cache/AbstractBroadcasterCache.java +++ b/modules/cpr/src/main/java/org/atmosphere/cache/AbstractBroadcasterCache.java @@ -53,7 +53,7 @@ public abstract class AbstractBroadcasterCache implements BroadcasterCache { @Override public void start() { - reaper.scheduleAtFixedRate(new Runnable() { + scheduledFuture = reaper.scheduleAtFixedRate(new Runnable() { public void run() { readWriteLock.writeLock().lock();