svn commit: r1469789 - /sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java

[cziegeler]

Author: cziegeler
Date: Fri Apr 19 11:41:43 2013
New Revision: 1469789

URL: http://svn.apache.org/r1469789
Log:
Distribute events in a cluster

Modified:
    
sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java

Modified: 
sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java?rev=1469789&r1=1469788&r2=1469789&view=diff
==============================================================================
--- 
sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
 (original)
+++ 
sling/trunk/contrib/extensions/mongodb/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
 Fri Apr 19 11:41:43 2013
@@ -97,6 +97,7 @@ public class MongoDBContext {
     public void notifyRemoved(final String[] info) {
         final Dictionary<String, Object> props = new Hashtable<String, 
Object>();
         props.put(SlingConstants.PROPERTY_PATH, this.rootWithSlash + info[0] + 
'/' + info[1]);
+        props.put("event.distribute", "");
         final Event event = new Event(SlingConstants.TOPIC_RESOURCE_REMOVED, 
props);
         this.eventAdmin.postEvent(event);
     }
@@ -104,6 +105,7 @@ public class MongoDBContext {
     public void notifyAddeed(final String[] info) {
         final Dictionary<String, Object> props = new Hashtable<String, 
Object>();
         props.put(SlingConstants.PROPERTY_PATH, this.rootWithSlash + info[0] + 
'/' + info[1]);
+        props.put("event.distribute", "");
         final Event event = new Event(SlingConstants.TOPIC_RESOURCE_ADDED, 
props);
         this.eventAdmin.postEvent(event);
     }
@@ -111,6 +113,7 @@ public class MongoDBContext {
     public void notifyUpdated(final String[] info) {
         final Dictionary<String, Object> props = new Hashtable<String, 
Object>();
         props.put(SlingConstants.PROPERTY_PATH, this.rootWithSlash + info[0] + 
'/' + info[1]);
+        props.put("event.distribute", "");
         final Event event = new Event(SlingConstants.TOPIC_RESOURCE_CHANGED, 
props);
         this.eventAdmin.postEvent(event);
     }