Fix for #933

Atmosphere · Feb 26, 2013 · d4fe314 · d4fe314
1 parent 82ed4c5
commit d4fe314
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/cpr/src/main/java/org/atmosphere/util/SimpleBroadcaster.java b/modules/cpr/src/main/java/org/atmosphere/util/SimpleBroadcaster.java
@@ -190,7 +190,7 @@ protected void prepareInvokeOnStateChange(final AtmosphereResource r, final Atmo
     @Override
     protected void queueWriteIO(AtmosphereResource r, Object finalMsg, Entry entry) throws InterruptedException {
         synchronized (r) {
-            executeAsyncWrite(new AsyncWriteToken(r, finalMsg, entry.future, entry.originalMessage));
+            executeAsyncWrite(new AsyncWriteToken(r, finalMsg, entry.future, entry.originalMessage, entry.cache));
         }
     }
 }