You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by ro...@apache.org on 2017/10/18 23:25:04 UTC
[sling-org-apache-sling-mongodb] 16/36: Distribute events in a
cluster
This is an automated email from the ASF dual-hosted git repository.
rombert pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-mongodb.git
commit 98644a07af7b469b6a83fa1e5357fece0541b2e0
Author: Carsten Ziegeler <cz...@apache.org>
AuthorDate: Fri Apr 19 11:41:43 2013 +0000
Distribute events in a cluster
git-svn-id: https://svn.apache.org/repos/asf/sling/trunk@1469789 13f79535-47bb-0310-9956-ffa450edef68
---
src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java b/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
index b1dc3fa..cd8ccc1 100644
--- a/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
+++ b/src/main/java/org/apache/sling/mongodb/impl/MongoDBContext.java
@@ -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);
}
--
To stop receiving notification emails like this one, please contact
"commits@sling.apache.org" <co...@sling.apache.org>.