You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2008/08/28 09:47:22 UTC
svn commit: r689748 -
/incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java
Author: cziegeler
Date: Thu Aug 28 00:47:22 2008
New Revision: 689748
URL: http://svn.apache.org/viewvc?rev=689748&view=rev
Log:
Don't redistribute local events.
Modified:
incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java
Modified: incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java
URL: http://svn.apache.org/viewvc/incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java?rev=689748&r1=689747&r2=689748&view=diff
==============================================================================
--- incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java (original)
+++ incubator/sling/trunk/extensions/event/src/main/java/org/apache/sling/event/impl/DistributingEventHandler.java Thu Aug 28 00:47:22 2008
@@ -145,16 +145,7 @@
}
if ( event != null && this.running ) {
try {
- final Node eventNode = this.writeEvent(event, null);
- final EventInfo info = new EventInfo();
- info.event = event;
- info.nodePath = eventNode.getPath();
- try {
- this.queue.put(info);
- } catch (InterruptedException e) {
- // we ignore this
- this.ignoreException(e);
- }
+ this.writeEvent(event, null);
} catch (Exception e) {
this.logger.error("Exception during writing the event to the repository.", e);
}