handle Expirable SpaceListeners

jpos · Jul 28, 2017 · 92b5d37 · 92b5d37
1 parent 82f6363
commit 92b5d37
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/modules/rspace/src/main/java/org/jpos/space/ReplicatedSpace.java b/modules/rspace/src/main/java/org/jpos/space/ReplicatedSpace.java
@@ -591,8 +591,12 @@ public void run() {
                 if (listeners != null) {
                     for (int i=0; i<listeners.length; i++) {
                         Object o = listeners[i];
-                        if (o instanceof SpaceListener)
-                            ((SpaceListener) o).notify (key, value);
+                        if (o instanceof TSpace.Expirable) {
+                            o = ((TSpace.Expirable)o).getValue();
+                        }
+                        if (o instanceof SpaceListener) {
+                            ((SpaceListener) o).notify(key, value);
+                        }
                     }
                 }
             }