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:10:06 UTC
svn commit: r1022839 -
/sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/queues/TopicRoundRobinJobQueue.java
Author: cziegeler
Date: Fri Oct 15 07:10:06 2010
New Revision: 1022839
URL: http://svn.apache.org/viewvc?rev=1022839&view=rev
Log:
Fix NPE on close
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=1022839&r1=1022838&r2=1022839&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:10:06 2010
@@ -75,6 +75,10 @@ public final class TopicRoundRobinJobQue
@Override
protected void put(final JobEvent event) {
+ // is this a close?
+ if ( event.event == null ) {
+ return;
+ }
final String topic = (String)event.event.getProperty(JobUtil.PROPERTY_JOB_TOPIC);
synchronized ( this.topicMap ) {
List<JobEvent> events = this.topicMap.get(topic);