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