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 2010/10/15 09:06:45 UTC

svn commit: r1022836 - /sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java

Author: cziegeler
Date: Fri Oct 15 07:06:45 2010
New Revision: 1022836

URL: http://svn.apache.org/viewvc?rev=1022836&view=rev
Log:
Fix wait statement

Modified:
    sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java

Modified: sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java
URL: http://svn.apache.org/viewvc/sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java?rev=1022836&r1=1022835&r2=1022836&view=diff
==============================================================================
--- sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java (original)
+++ sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java Fri Oct 15 07:06:45 2010
@@ -102,7 +102,7 @@ public final class TopicRoundRobinJobQue
                 this.isWaitingForNext = true;
                 while ( this.isWaitingForNext ) {
                     try {
-                        this.wait();
+                        this.topicMap.wait();
                     } catch (final InterruptedException ie) {
                         this.ignoreException(ie);
                     }