Fix for #248 [runtime] Add support for CacheMessage ID

Atmosphere · Mar 28, 2012 · 4563082 · 4563082
1 parent 75cb5f8
commit 4563082
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/modules/cpr/src/main/java/org/atmosphere/cache/BroadcasterCacheBase.java b/modules/cpr/src/main/java/org/atmosphere/cache/BroadcasterCacheBase.java
@@ -239,6 +239,7 @@ protected final static class CachedMessage implements Serializable {
         public final long currentTime;
         public CachedMessage next;
         public final boolean isTail;
+        public Object t;
 
         public CachedMessage(boolean isTail) {
             this.currentTime = 0L;
@@ -283,5 +284,14 @@ public boolean isTail() {
             return isTail;
         }
 
+        public CachedMessage setKey(Object t) {
+            this.t = t;
+            return this;
+        }
+
+        public Object getKey() {
+            return t;
+        }
+
     }
 }