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 2013/05/07 16:27:41 UTC

svn commit: r1479919 - /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java

Author: cziegeler
Date: Tue May  7 14:27:41 2013
New Revision: 1479919

URL: http://svn.apache.org/r1479919
Log:
SLING-2829 : Don't remove timed event if it's in the past

Modified:
    sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java

Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java?rev=1479919&r1=1479918&r2=1479919&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/timed/TimedEventSender.java Tue May  7 14:27:41 2013
@@ -313,16 +313,10 @@ public class TimedEventSender
                     localScheduler.addPeriodicJob(scheduleInfo.jobId, this, config, scheduleInfo.period, false);
                 } else {
                     // then it must be date
-                    if ( scheduleInfo.date.getTime() <= System.currentTimeMillis() ) {
-                        // obsolete date, remove it
-                        this.removeEvent(scheduleInfo);
-                        return true;
-                    } else {
-                        if ( this.logger.isDebugEnabled() ) {
-                            this.logger.debug("Adding timed event " + config.get(JOB_TOPIC) + "(" + scheduleInfo.jobId + ")" + " with date " + scheduleInfo.date);
-                        }
-                        localScheduler.fireJobAt(scheduleInfo.jobId, this, config, scheduleInfo.date);
+                    if ( this.logger.isDebugEnabled() ) {
+                        this.logger.debug("Adding timed event " + config.get(JOB_TOPIC) + "(" + scheduleInfo.jobId + ")" + " with date " + scheduleInfo.date);
                     }
+                    localScheduler.fireJobAt(scheduleInfo.jobId, this, config, scheduleInfo.date);
                 }
                 this.startedSchedulerJobs.add(scheduleInfo.jobId);
                 return true;