1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
/**
 * Copyright (C) 2007  Bull S. A. S.
 * Bull, Rue Jean Jaures, B.P.68, 78340, Les Clayes-sous-Bois
 * This library is free software; you can redistribute it and/or modify it under the terms
 * of the GNU Lesser General Public License as published by the Free Software Foundation
 * version 2.1 of the License.
 * This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU Lesser General Public License for more details.
 * You should have received a copy of the GNU Lesser General Public License along with this
 * program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth
 * Floor, Boston, MA  02110-1301, USA.
 **/
package org.jbpm.pvm.internal.jobexecutor;
 
import java.util.List;
 
import org.hibernate.Query;
import org.hibernate.Session;
import org.jbpm.api.Execution;
import org.jbpm.api.JbpmException;
import org.jbpm.api.job.Timer;
import org.jbpm.internal.log.Log;
import org.jbpm.pvm.internal.job.TimerImpl;
import org.jbpm.pvm.internal.session.TimerSession;
import org.jbpm.pvm.internal.tx.Transaction;
 
/**
 * Timers created with this service are committed at the end of the transaction,
 * so their execution will be late if the delay is shorter than the transaction.
 * In that case, they will be executed at the end of the transaction.
 * 
 * @author Tom Baeyens, Pascal Verdage
 */
public class JobExecutorTimerSession implements TimerSession {
 
  private static final Log log = Log.getLog(TimerSession.class.getName());
 
  /* injected */
  Transaction transaction;
 
  /* injected */
  JobExecutor jobExecutor;
 
  /* injected */
  Session session;
 
  boolean jobExecutorNotificationScheduled = false;
 
  public void schedule(Timer timer) {
    if (timer == null) throw new JbpmException("null timer scheduled");
    if (timer.getExecution() == null) throw new JbpmException("timer has no execution specified");
    if ((timer.getSignalName() == null) && (timer.getEventName() == null)) throw new JbpmException("timer has no signalName or eventName specified");
    if (timer.getDueDate() == null) throw new JbpmException("timer scheduled at null date");
 
    log.debug("scheduling " + timer);
    session.save(timer);
    
    if ( (!jobExecutorNotificationScheduled)
         && (jobExecutor!=null)
       ) {
      jobExecutorNotificationScheduled = true;
      
      //a transaction is not required (can be null)
      if (transaction != null) {
        transaction.registerSynchronization(new JobAddedNotification(jobExecutor));          
      }
    }
  }
 
  public void cancel(Timer timer) {
    log.debug("canceling " + timer);
    if (timer != null) {
      session.delete(timer);
    } else {
      throw new JbpmException("timer is null");
    }
  }
 
  public List<Timer> findTimersByExecution(Execution execution) {
    Query query = session.createQuery(
      "select timer " +
      "from "+TimerImpl.class.getName()+" timer " +
      "where timer.execution = :execution"
    );
    query.setEntity("execution", execution);
    return query.list();
  }
}