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);
}