• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java TimerDeclarationImpl类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl的典型用法代码示例。如果您正苦于以下问题:Java TimerDeclarationImpl类的具体用法?Java TimerDeclarationImpl怎么用?Java TimerDeclarationImpl使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



TimerDeclarationImpl类属于org.activiti.engine.impl.jobexecutor包,在下文中一共展示了TimerDeclarationImpl类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: checkStartEventDefinitions

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
protected int checkStartEventDefinitions(ProcessDefinition def, String embededActivityId) {
    List<TimerDeclarationImpl> startTimerDeclarations = (List<TimerDeclarationImpl>) ((ProcessDefinitionEntity) def).getProperty("timerStart");

    if (startTimerDeclarations != null && startTimerDeclarations.size() > 0) {
        TimerDeclarationImpl timerDeclaration = null;

        for (TimerDeclarationImpl startTimerDeclaration : startTimerDeclarations) {
            String definitionActivityId = TimerEventHandler.getActivityIdFromConfiguration(startTimerDeclaration.getJobHandlerConfiguration());
            if (startTimerDeclaration.getJobHandlerType().equalsIgnoreCase(jobHandlerType)
                    && (definitionActivityId.equalsIgnoreCase(embededActivityId))) {
                timerDeclaration = startTimerDeclaration;
            }
        }

        if (timerDeclaration != null) {
            return calculateMaxIterationsValue(timerDeclaration.getDescription().getExpressionText());
        }
    }
    return 1;
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:21,代码来源:TimerJobEntity.java


示例2: addTimerDeclarations

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void addTimerDeclarations(ProcessDefinitionEntity processDefinition, List<TimerJobEntity> timers) {
    List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) processDefinition.getProperty(BpmnParse.PROPERTYNAME_START_TIMER);
    if (timerDeclarations != null) {
        for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
            TimerJobEntity timer = timerDeclaration.prepareTimerEntity(null);
            if (timer != null) {
                timer.setProcessDefinitionId(processDefinition.getId());

                // Inherit timer (if applicable)
                if (processDefinition.getTenantId() != null) {
                    timer.setTenantId(processDefinition.getTenantId());
                }
                timers.add(timer);
            }
        }
    }
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:19,代码来源:BpmnDeployer.java


示例3: initialize

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void initialize() {
  log.fine("initializing "+this);

  ScopeImpl scope = getScope();
  ensureParentInitialized();

  List<VariableDeclaration> variableDeclarations = (List<VariableDeclaration>) scope.getProperty(BpmnParse.PROPERTYNAME_VARIABLE_DECLARATIONS);
  if (variableDeclarations!=null) {
    for (VariableDeclaration variableDeclaration : variableDeclarations) {
      variableDeclaration.initialize(this, parent);
    }
  }
  
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(BpmnParse.PROPERTYNAME_TIMER_DECLARATION);
  if (timerDeclarations!=null) {
    for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
      TimerEntity timer = timerDeclaration.prepareTimerEntity(this);
      Context
        .getCommandContext()
        .getJobManager()
        .schedule(timer);
    }
  }
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:26,代码来源:ExecutionEntity.java


示例4: parseTimer

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
private TimerDeclarationImpl parseTimer(Element timerEventDefinition, ScopeImpl timerActivity, String jobHandlerType) {
  // TimeDate
  TimerDeclarationType type = TimerDeclarationType.DATE;
  Expression expression = parseExpression(timerEventDefinition, "timeDate");

  // TimeCycle
  if (expression == null) {
    type = TimerDeclarationType.CYCLE;
    expression = parseExpression(timerEventDefinition, "timeCycle");
  }

  // TimeDuration
  if (expression == null) {
    type = TimerDeclarationType.DURATION;
    expression = parseExpression(timerEventDefinition, "timeDuration");
  }

  // Parse the timer declaration
  // TODO move the timer declaration into the bpmn activity or next to the
  // TimerSession
  TimerDeclarationImpl timerDeclaration = new TimerDeclarationImpl(expression, type, jobHandlerType);
  timerDeclaration.setJobHandlerConfiguration(timerActivity.getId());
  return timerDeclaration;
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:25,代码来源:BpmnParse.java


示例5: TimerJobEntity

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
public TimerJobEntity(TimerDeclarationImpl timerDeclaration) {
    this.jobHandlerType = timerDeclaration.getJobHandlerType();
    this.jobHandlerConfiguration = timerDeclaration.getJobHandlerConfiguration();
    this.isExclusive = timerDeclaration.isExclusive();
    this.repeat = timerDeclaration.getRepeat();
    this.retries = timerDeclaration.getRetries();
    this.jobType = "timer";
    this.revision = 1;
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:10,代码来源:TimerJobEntity.java


示例6: initialize

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public void initialize() {
    LOGGER.debug("initializing {}", this);

    ScopeImpl scope = getScopeObject();
    ensureParentInitialized();

    // initialize the lists of referenced objects (prevents db queries)
    variableInstances = new HashMap<>();
    eventSubscriptions = new ArrayList<>();

    // Cached entity-state initialized to null, all bits are zero, indicating NO entities present
    cachedEntityState = 0;

    List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(BpmnParse.PROPERTYNAME_TIMER_DECLARATION);
    if (timerDeclarations != null) {
        for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
            TimerJobEntity timer = timerDeclaration.prepareTimerEntity(this);
            if (timer != null) {
                callJobProcessors(JobProcessorContext.Phase.BEFORE_CREATE, timer, Context.getProcessEngineConfiguration());
                Context.getCommandContext().getJobEntityManager().schedule(timer);
            }
        }
    }

    // create event subscriptions for the current scope
    List<EventSubscriptionDeclaration> eventSubscriptionDeclarations = (List<EventSubscriptionDeclaration>) scope.getProperty(BpmnParse.PROPERTYNAME_EVENT_SUBSCRIPTION_DECLARATION);
    if (eventSubscriptionDeclarations != null) {
        for (EventSubscriptionDeclaration eventSubscriptionDeclaration : eventSubscriptionDeclarations) {
            if (!eventSubscriptionDeclaration.isStartEvent()) {
                EventSubscriptionEntity eventSubscriptionEntity = eventSubscriptionDeclaration.prepareEventSubscriptionEntity(this);
                if (getTenantId() != null) {
                    eventSubscriptionEntity.setTenantId(getTenantId());
                }
                eventSubscriptionEntity.insert();
            }
        }
    }
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:41,代码来源:ExecutionEntity.java


示例7: addTimerDeclaration

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void addTimerDeclaration(ScopeImpl scope, TimerDeclarationImpl timerDeclaration) {
    List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(PROPERTYNAME_TIMER_DECLARATION);
    if (timerDeclarations == null) {
        timerDeclarations = new ArrayList<>();
        scope.setProperty(PROPERTYNAME_TIMER_DECLARATION, timerDeclarations);
    }
    timerDeclarations.add(timerDeclaration);
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:10,代码来源:TimerEventDefinitionParseHandler.java


示例8: TimerEntity

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
public TimerEntity(TimerDeclarationImpl timerDeclaration) {
  jobHandlerType = timerDeclaration.getJobHandlerType();
  jobHandlerConfiguration = timerDeclaration.getJobHandlerConfiguration();
  isExclusive = timerDeclaration.isExclusive();
  repeat = timerDeclaration.getRepeat();
  retries = timerDeclaration.getRetries();
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:8,代码来源:TimerEntity.java


示例9: parseTimerStartEventDefinition

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void parseTimerStartEventDefinition(Element timerEventDefinition, ActivityImpl timerActivity, ProcessDefinitionEntity processDefinition) {
  timerActivity.setProperty("type", "startTimerEvent");
  TimerDeclarationImpl timerDeclaration = parseTimer(timerEventDefinition, timerActivity, TimerStartEventJobHandler.TYPE);
  timerDeclaration.setJobHandlerConfiguration(processDefinition.getKey());

  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) processDefinition.getProperty(PROPERTYNAME_START_TIMER);
  if (timerDeclarations == null) {
    timerDeclarations = new ArrayList<TimerDeclarationImpl>();
    processDefinition.setProperty(PROPERTYNAME_START_TIMER, timerDeclarations);
  }
  timerDeclarations.add(timerDeclaration);

}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:15,代码来源:BpmnParse.java


示例10: parseIntemediateTimerEventDefinition

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
private void parseIntemediateTimerEventDefinition(Element timerEventDefinition, ActivityImpl timerActivity) {
  timerActivity.setProperty("type", "intermediateTimer");
  TimerDeclarationImpl timerDeclaration = parseTimer(timerEventDefinition, timerActivity, TimerCatchIntermediateEventJobHandler.TYPE);
  addTimerDeclaration(timerActivity, timerDeclaration);
  timerActivity.setScope(true);
  for (BpmnParseListener parseListener : parseListeners) {
    parseListener.parseIntermediateTimerEventDefinition(timerEventDefinition, timerActivity);
  }
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:10,代码来源:BpmnParse.java


示例11: addTimerDeclaration

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void addTimerDeclaration(ScopeImpl scope, TimerDeclarationImpl timerDeclaration) {
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(PROPERTYNAME_TIMER_DECLARATION);
  if (timerDeclarations == null) {
    timerDeclarations = new ArrayList<TimerDeclarationImpl>();
    scope.setProperty(PROPERTYNAME_TIMER_DECLARATION, timerDeclarations);
  }
  timerDeclarations.add(timerDeclaration);
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:10,代码来源:BpmnParse.java


示例12: addTimerDeclarations

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void addTimerDeclarations(ProcessDefinitionEntity processDefinition) {
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) processDefinition.getProperty(BpmnParse.PROPERTYNAME_START_TIMER);
  if (timerDeclarations!=null) {
    for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
      TimerEntity timer = timerDeclaration.prepareTimerEntity(null);
      Context
        .getCommandContext()
        .getJobManager()
        .schedule(timer);
    }
  }
}
 
开发者ID:logicalhacking,项目名称:SecureBPMN,代码行数:14,代码来源:BpmnDeployer.java


示例13: parseTimerStartEventDefinition

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void parseTimerStartEventDefinition(Element timerEventDefinition, ActivityImpl timerActivity, ProcessDefinitionEntity processDefinition) {
  timerActivity.setProperty("type", "startTimerEvent");
  TimerDeclarationImpl timerDeclaration = parseTimer(timerEventDefinition, timerActivity, TimerStartEventJobHandler.TYPE);
  timerDeclaration.setJobHandlerConfiguration(processDefinition.getKey());    

  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) processDefinition.getProperty(PROPERTYNAME_START_TIMER);
  if (timerDeclarations == null) {
    timerDeclarations = new ArrayList<TimerDeclarationImpl>();
    processDefinition.setProperty(PROPERTYNAME_START_TIMER, timerDeclarations);
  }
  timerDeclarations.add(timerDeclaration);

}
 
开发者ID:iotsap,项目名称:FiWare-Template-Handler,代码行数:15,代码来源:BpmnParse.java


示例14: parseIntemediateTimerEventDefinition

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
private void parseIntemediateTimerEventDefinition(Element timerEventDefinition, ActivityImpl timerActivity, boolean isAfterEventBasedGateway) {
  timerActivity.setProperty("type", "intermediateTimer");
  TimerDeclarationImpl timerDeclaration = parseTimer(timerEventDefinition, timerActivity, TimerCatchIntermediateEventJobHandler.TYPE);
  if(isAfterEventBasedGateway) {
    addTimerDeclaration(timerActivity.getParent(), timerDeclaration);
  }else {
    addTimerDeclaration(timerActivity, timerDeclaration);
    timerActivity.setScope(true);
  }
  for (BpmnParseListener parseListener : parseListeners) {
    parseListener.parseIntermediateTimerEventDefinition(timerEventDefinition, timerActivity);
  }
}
 
开发者ID:iotsap,项目名称:FiWare-Template-Handler,代码行数:14,代码来源:BpmnParse.java


示例15: parseTimer

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
private TimerDeclarationImpl parseTimer(Element timerEventDefinition, ScopeImpl timerActivity, String jobHandlerType) {
  // TimeDate
  TimerDeclarationType type = TimerDeclarationType.DATE;
  Expression expression = parseExpression(timerEventDefinition, "timeDate");
  // TimeCycle
  if (expression == null) {
    type = TimerDeclarationType.CYCLE;
    expression = parseExpression(timerEventDefinition, "timeCycle");
  }
  // TimeDuration
  if (expression == null) {
    type = TimerDeclarationType.DURATION;
    expression = parseExpression(timerEventDefinition, "timeDuration");
  }    
  // neither date, cycle or duration configured!
  if (expression==null) {
    addError("Timer needs configuration (either timeDate, timeCycle or timeDuration is needed).", timerEventDefinition);      
  }    

  // Parse the timer declaration
  // TODO move the timer declaration into the bpmn activity or next to the
  // TimerSession
  TimerDeclarationImpl timerDeclaration = new TimerDeclarationImpl(expression, type, jobHandlerType);
  timerDeclaration.setJobHandlerConfiguration(timerActivity.getId());
  timerDeclaration.setExclusive("true".equals(timerEventDefinition.attributeNS(BpmnParser.ACTIVITI_BPMN_EXTENSIONS_NS, "exclusive", String.valueOf(JobEntity.DEFAULT_EXCLUSIVE))));
  return timerDeclaration;
}
 
开发者ID:iotsap,项目名称:FiWare-Template-Handler,代码行数:28,代码来源:BpmnParse.java


示例16: initialize

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void initialize() {
  log.debug("initializing {}", this);

  ScopeImpl scope = getScopeObject();
  ensureParentInitialized();

  // initialize the lists of referenced objects (prevents db queries)
  variableInstances = new HashMap<String, VariableInstanceEntity>();
  eventSubscriptions = new ArrayList<EventSubscriptionEntity>();
  jobs = new ArrayList<JobEntity>();
  tasks = new ArrayList<TaskEntity>();
  
  // Cached entity-state initialized to null, all bits are zore, indicating NO entities present
  cachedEntityState = 0;
  
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(BpmnParse.PROPERTYNAME_TIMER_DECLARATION);
  if (timerDeclarations!=null) {
    for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
      TimerEntity timer = timerDeclaration.prepareTimerEntity(this);
      Context
        .getCommandContext()
        .getJobEntityManager()
        .schedule(timer);        
    }
  }
  
  // create event subscriptions for the current scope
  List<EventSubscriptionDeclaration> eventSubscriptionDeclarations = (List<EventSubscriptionDeclaration>) scope.getProperty(BpmnParse.PROPERTYNAME_EVENT_SUBSCRIPTION_DECLARATION);
  if(eventSubscriptionDeclarations != null) {
    for (EventSubscriptionDeclaration eventSubscriptionDeclaration : eventSubscriptionDeclarations) {        
      if(!eventSubscriptionDeclaration.isStartEvent()) {
        EventSubscriptionEntity eventSubscriptionEntity = eventSubscriptionDeclaration.prepareEventSubscriptionEntity(this);        
        eventSubscriptionEntity.insert();
      }        
    }
  }
}
 
开发者ID:springvelocity,项目名称:xbpm5,代码行数:39,代码来源:ExecutionEntity.java


示例17: createTimer

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
protected TimerDeclarationImpl createTimer(BpmnParse bpmnParse, TimerEventDefinition timerEventDefinition, ScopeImpl timerActivity, String jobHandlerType) {
  TimerDeclarationType type = null;
  Expression expression = null;
  ExpressionManager expressionManager = bpmnParse.getExpressionManager();
  if (StringUtils.isNotEmpty(timerEventDefinition.getTimeDate())) {
    // TimeDate
    type = TimerDeclarationType.DATE;
    expression = expressionManager.createExpression(timerEventDefinition.getTimeDate());
  } else if (StringUtils.isNotEmpty(timerEventDefinition.getTimeCycle())) {
    // TimeCycle
    type = TimerDeclarationType.CYCLE;
    expression = expressionManager.createExpression(timerEventDefinition.getTimeCycle());
  } else if (StringUtils.isNotEmpty(timerEventDefinition.getTimeDuration())) {
    // TimeDuration
    type = TimerDeclarationType.DURATION;
    expression = expressionManager.createExpression(timerEventDefinition.getTimeDuration());
  }    
  
  // neither date, cycle or duration configured!
  if (expression == null) {
    bpmnParse.getBpmnModel().addProblem("Timer needs configuration (either timeDate, timeCycle or timeDuration is needed).", timerEventDefinition);      
  }    

  // Parse the timer declaration
  // TODO move the timer declaration into the bpmn activity or next to the
  // TimerSession
  TimerDeclarationImpl timerDeclaration = new TimerDeclarationImpl(expression, type, jobHandlerType);
  timerDeclaration.setJobHandlerConfiguration(timerActivity.getId());
  timerDeclaration.setExclusive(true);
  return timerDeclaration;
}
 
开发者ID:springvelocity,项目名称:xbpm5,代码行数:32,代码来源:TimerEventDefinitionParseHandler.java


示例18: addTimerDeclarations

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void addTimerDeclarations(ProcessDefinitionEntity processDefinition) {
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) processDefinition.getProperty(BpmnParse.PROPERTYNAME_START_TIMER);
  if (timerDeclarations!=null) {
    for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
      TimerEntity timer = timerDeclaration.prepareTimerEntity(null);
      timer.setProcessDefinitionId(processDefinition.getId());
      Context
        .getCommandContext()
        .getJobEntityManager()
        .schedule(timer);
    }
  }
}
 
开发者ID:springvelocity,项目名称:xbpm5,代码行数:15,代码来源:BpmnDeployer.java


示例19: createTimer

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
protected TimerDeclarationImpl createTimer(BpmnParse bpmnParse, TimerEventDefinition timerEventDefinition, ScopeImpl timerActivity, String jobHandlerType) {
    TimerDeclarationType type = null;
    Expression expression = null;
    Expression endDate = null;
    Expression calendarName = null;
    ExpressionManager expressionManager = bpmnParse.getExpressionManager();
    if (StringUtils.isNotEmpty(timerEventDefinition.getTimeDate())) {
        // TimeDate
        type = TimerDeclarationType.DATE;
        expression = expressionManager.createExpression(timerEventDefinition.getTimeDate());
    } else if (StringUtils.isNotEmpty(timerEventDefinition.getTimeCycle())) {
        // TimeCycle
        type = TimerDeclarationType.CYCLE;
        expression = expressionManager.createExpression(timerEventDefinition.getTimeCycle());
        // support for endDate
        if (StringUtils.isNotEmpty(timerEventDefinition.getEndDate())) {
            endDate = expressionManager.createExpression(timerEventDefinition.getEndDate());
        }
    } else if (StringUtils.isNotEmpty(timerEventDefinition.getTimeDuration())) {
        // TimeDuration
        type = TimerDeclarationType.DURATION;
        expression = expressionManager.createExpression(timerEventDefinition.getTimeDuration());
    }

    if (StringUtils.isNotEmpty(timerEventDefinition.getCalendarName())) {
        calendarName = expressionManager.createExpression(timerEventDefinition.getCalendarName());
    }

    // neither date, cycle or duration configured!
    if (expression == null) {
        LOGGER.warn("Timer needs configuration (either timeDate, timeCycle or timeDuration is needed) ({})", timerActivity.getId());
    }

    String jobHandlerConfiguration = timerActivity.getId();

    if (jobHandlerType.equalsIgnoreCase(TimerExecuteNestedActivityJobHandler.TYPE) ||
            jobHandlerType.equalsIgnoreCase(TimerCatchIntermediateEventJobHandler.TYPE) ||
            jobHandlerType.equalsIgnoreCase(TimerStartEventJobHandler.TYPE)) {
        jobHandlerConfiguration = TimerStartEventJobHandler.createConfiguration(timerActivity.getId(), endDate, calendarName);
    }

    // Parse the timer declaration
    // TODO move the timer declaration into the bpmn activity or next to the
    // TimerSession
    TimerDeclarationImpl timerDeclaration = new TimerDeclarationImpl(expression, type, jobHandlerType, endDate, calendarName);
    timerDeclaration.setJobHandlerConfiguration(jobHandlerConfiguration);

    timerDeclaration.setExclusive(true);
    return timerDeclaration;
}
 
开发者ID:flowable,项目名称:flowable-engine,代码行数:51,代码来源:TimerEventDefinitionParseHandler.java


示例20: initialize

import org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void initialize() {
  log.fine("initializing "+this);

  ScopeImpl scope = getScope();
  ensureParentInitialized();

  List<VariableDeclaration> variableDeclarations = (List<VariableDeclaration>) scope.getProperty(BpmnParse.PROPERTYNAME_VARIABLE_DECLARATIONS);
  if (variableDeclarations!=null) {
    for (VariableDeclaration variableDeclaration : variableDeclarations) {
      variableDeclaration.initialize(this, parent);
    }
  }
  
  List<DataObject> dataObjects = (List<DataObject>) scope.getDataObjects();
  if (dataObjects != null) {
  	for (DataObject dataObject : dataObjects) {
  		setVariable(dataObject.getName(), null);
  	}
  }
  
  
  List<TimerDeclarationImpl> timerDeclarations = (List<TimerDeclarationImpl>) scope.getProperty(BpmnParse.PROPERTYNAME_TIMER_DECLARATION);
  if (timerDeclarations!=null) {
    for (TimerDeclarationImpl timerDeclaration : timerDeclarations) {
      TimerEntity timer = timerDeclaration.prepareTimerEntity(this);
      Context
        .getCommandContext()
        .getJobManager()
        .schedule(timer);
    }
  }
  
  List<SignalEventDefinition> signalDefinitions = (List<SignalEventDefinition>) scope.getProperty(BpmnParse.PROPERTYNAME_SIGNAL_DEFINITION_NAME);
  if(signalDefinitions != null) {
    for (SignalEventDefinition signalDefinition : signalDefinitions) {
      SignalEventSubscriptionEntity signalEventSubscriptionEntity = new SignalEventSubscriptionEntity(this);
      signalEventSubscriptionEntity.setEventName(signalDefinition.getSignalName());    
      if(signalDefinition.getActivityId() != null) {
        ActivityImpl activity = getActivity().findActivity(signalDefinition.getActivityId());
        signalEventSubscriptionEntity.setActivity(activity);
      }
      Context 
        .getCommandContext()
        .getEventSubscriptionManager()
        .insert(signalEventSubscriptionEntity);
    }
  }
}
 
开发者ID:iotsap,项目名称:FiWare-Template-Handler,代码行数:50,代码来源:ExecutionEntity.java



注:本文中的org.activiti.engine.impl.jobexecutor.TimerDeclarationImpl类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java SQLInsertClause类代码示例发布时间:2022-05-22
下一篇:
Java R类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap