本文整理汇总了Java中org.activiti.bpmn.model.BaseElement类的典型用法代码示例。如果您正苦于以下问题:Java BaseElement类的具体用法?Java BaseElement怎么用?Java BaseElement使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
BaseElement类属于org.activiti.bpmn.model包,在下文中一共展示了BaseElement类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: processJsonElements
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public void processJsonElements(JsonNode shapesArrayNode,
JsonNode modelNode, BaseElement parentElement,
Map<String, JsonNode> shapeMap, BpmnModel bpmnModel) {
for (JsonNode shapeNode : shapesArrayNode) {
String stencilId = BpmnJsonConverterUtil.getStencilId(shapeNode);
Class<? extends BaseBpmnJsonConverter> converter = convertersToBpmnMap
.get(stencilId);
try {
BaseBpmnJsonConverter converterInstance = converter
.newInstance();
converterInstance.convertToBpmnModel(shapeNode, modelNode,
this, parentElement, shapeMap, bpmnModel);
} catch (Exception e) {
LOGGER.error("Error converting {}",
BpmnJsonConverterUtil.getStencilId(shapeNode), e);
}
}
}
开发者ID:zhaojunfei,项目名称:lemon,代码行数:20,代码来源:BpmnJsonConverter.java
示例2: parse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public void parse(BpmnParse bpmnParse, BaseElement baseElement) {
if (!(baseElement instanceof UserTask)) {
return;
}
if (useDefaultUserTaskParser) {
new UserTaskParseHandler().parse(bpmnParse, baseElement);
}
UserTask userTask = (UserTask) baseElement;
logger.debug("bpmnParse : {}, userTask : {}", bpmnParse, userTask);
TaskDefinition taskDefinition = (TaskDefinition) bpmnParse
.getCurrentActivity().getProperty(
UserTaskParseHandler.PROPERTY_TASK_DEFINITION);
this.configEvent(taskDefinition, bpmnParse,
TaskListener.EVENTNAME_CREATE);
this.configEvent(taskDefinition, bpmnParse,
TaskListener.EVENTNAME_ASSIGNMENT);
this.configEvent(taskDefinition, bpmnParse,
TaskListener.EVENTNAME_COMPLETE);
this.configEvent(taskDefinition, bpmnParse,
TaskListener.EVENTNAME_DELETE);
}
开发者ID:zhaojunfei,项目名称:lemon,代码行数:26,代码来源:ProxyUserTaskBpmnParseHandler.java
示例3: parse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
public void parse(BpmnParse bpmnParse, BaseElement element) {
if (element instanceof Process) {
ProcessDefinitionEntity processDefinition = bpmnParse.getCurrentProcessDefinition();
String key = processDefinition.getKey();
processDefinition.setKey(key + "-modified-by-post-parse-handler");
} else if (element instanceof UserTask) {
UserTask userTask = (UserTask) element;
List<SequenceFlow> outgoingFlows = userTask.getOutgoingFlows();
System.out.println("UserTask:[" + userTask.getName() + "]的输出流:");
for (SequenceFlow outgoingFlow : outgoingFlows) {
System.out.println("\t" + outgoingFlow.getTargetRef());
}
System.out.println();
}
}
开发者ID:shawn-gogh,项目名称:myjavacode,代码行数:17,代码来源:MyPostParseHandler.java
示例4: executeParse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected void executeParse(BpmnParse bpmnParse, BaseElement baseElement) {
ProcessDefinitionEntity processDefinitionEntity = bpmnParse.getCurrentProcessDefinition();
// We have to check if the data publishing listener has already been associated at server startup.
ExecutionListener processTerminationListener = null;
List<ExecutionListener> endListeners = processDefinitionEntity.getExecutionListeners(PvmEvent.EVENTNAME_END);
if (endListeners != null) {
for (ExecutionListener listener : endListeners) {
if (listener instanceof ProcessTerminationListener) {
processTerminationListener = listener;
break;
}
}
}
if (processTerminationListener == null) {
if (log.isDebugEnabled()) {
log.debug("Enabling data publishing for process: " + processDefinitionEntity.getName());
}
processDefinitionEntity.addExecutionListener(PvmEvent.EVENTNAME_END, new ProcessTerminationListener());
}
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:23,代码来源:ProcessParseHandler.java
示例5: executeParse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected void executeParse(BpmnParse bpmnParse, BaseElement baseElement) {
ProcessDefinitionEntity processDefinitionEntity = bpmnParse.getCurrentProcessDefinition();
// We have to check if the data publishing KPI listener has already been associated at server startup.
ExecutionListener processTerminationKPIListener = null;
List<ExecutionListener> endListeners = processDefinitionEntity.getExecutionListeners(PvmEvent.EVENTNAME_END);
if (endListeners != null) {
for (ExecutionListener listener : endListeners) {
if (listener instanceof ProcessTerminationKPIListener) {
processTerminationKPIListener = listener;
}
}
}
if (processTerminationKPIListener == null) {
if (log.isDebugEnabled()) {
log.debug("Enabling data publishing for process: " + processDefinitionEntity.getName());
}
processDefinitionEntity.addExecutionListener(PvmEvent.EVENTNAME_END, new ProcessTerminationKPIListener());
}
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:22,代码来源:ProcessKPIParseHandler.java
示例6: executeParse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected void executeParse(BpmnParse bpmnParse, BaseElement element) {
TaskDefinition taskDefinition = (TaskDefinition) bpmnParse.getCurrentActivity().getProperty(UserTaskParseHandler.PROPERTY_TASK_DEFINITION);
// We have to check if data publishing listener has already been associated at server startup
TaskListener taskCompletionListener = null;
List<TaskListener> completionListeners = taskDefinition.getTaskListener(TaskListener.EVENTNAME_COMPLETE);
if (completionListeners != null) {
for (TaskListener listener : completionListeners) {
if (listener instanceof TaskCompletionListener) {
taskCompletionListener = listener;
break;
}
}
}
if (taskCompletionListener == null) {
if (log.isDebugEnabled()) {
log.debug("Adding data publishing listener to task: " + taskDefinition.getKey());
}
taskDefinition.addTaskListener(TaskListener.EVENTNAME_COMPLETE, new TaskCompletionListener());
}
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:23,代码来源:TaskParseHandler.java
示例7: processFlowElements
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
private void processFlowElements(Collection<FlowElement> flowElementList, BaseElement parentScope) {
for (FlowElement flowElement : flowElementList) {
if (flowElement instanceof SequenceFlow) {
SequenceFlow sequenceFlow = (SequenceFlow) flowElement;
FlowNode sourceNode = getFlowNodeFromScope(sequenceFlow.getSourceRef(), parentScope);
if (sourceNode != null) {
sourceNode.getOutgoingFlows().add(sequenceFlow);
}
FlowNode targetNode = getFlowNodeFromScope(sequenceFlow.getTargetRef(), parentScope);
if (targetNode != null) {
targetNode.getIncomingFlows().add(sequenceFlow);
}
} else if (flowElement instanceof BoundaryEvent) {
BoundaryEvent boundaryEvent = (BoundaryEvent) flowElement;
FlowElement attachedToElement = getFlowNodeFromScope(boundaryEvent.getAttachedToRefId(), parentScope);
if(attachedToElement != null) {
boundaryEvent.setAttachedToRef((Activity) attachedToElement);
((Activity) attachedToElement).getBoundaryEvents().add(boundaryEvent);
}
} else if(flowElement instanceof SubProcess) {
SubProcess subProcess = (SubProcess) flowElement;
processFlowElements(subProcess.getFlowElements(), subProcess);
}
}
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:26,代码来源:BpmnXMLConverter.java
示例8: parseElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public void parseElement(BpmnParse bpmnParse, BaseElement element) {
if (element instanceof FlowElement) {
bpmnParse.setCurrentFlowElement((FlowElement) element);
}
// Execute parse handlers
List<BpmnParseHandler> handlers = parseHandlers.get(element.getClass());
if (handlers == null) {
LOGGER.warn("Could not find matching parse handler for + " + element.getId() + " this is likely a bug.");
} else {
for (BpmnParseHandler handler : handlers) {
handler.parse(bpmnParse, element);
}
}
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:18,代码来源:BpmnParseHandlers.java
示例9: parseChildElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public void parseChildElement(XMLStreamReader xtr, BaseElement parentElement, BpmnModel model) throws Exception {
String source = xtr.getAttributeValue(null, ATTRIBUTE_IOPARAMETER_SOURCE);
String sourceExpression = xtr.getAttributeValue(null, ATTRIBUTE_IOPARAMETER_SOURCE_EXPRESSION);
String target = xtr.getAttributeValue(null, ATTRIBUTE_IOPARAMETER_TARGET);
if((StringUtils.isNotEmpty(source) || StringUtils.isNotEmpty(sourceExpression)) && StringUtils.isNotEmpty(target)) {
IOParameter parameter = new IOParameter();
if(StringUtils.isNotEmpty(sourceExpression)) {
parameter.setSourceExpression(sourceExpression);
} else {
parameter.setSource(source);
}
parameter.setTarget(target);
((CallActivity) parentElement).getOutParameters().add(parameter);
}
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:19,代码来源:CallActivityXMLConverter.java
示例10: parseChildElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public void parseChildElement(XMLStreamReader xtr, BaseElement parentElement, BpmnModel model) throws Exception {
if (parentElement instanceof Event == false) return;
SignalEventDefinition eventDefinition = new SignalEventDefinition();
BpmnXMLUtil.addXMLLocation(eventDefinition, xtr);
eventDefinition.setSignalRef(xtr.getAttributeValue(null, ATTRIBUTE_SIGNAL_REF));
if (StringUtils.isNotEmpty(xtr.getAttributeValue(ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_ACTIVITY_ASYNCHRONOUS))) {
eventDefinition.setAsync(Boolean.parseBoolean(xtr.getAttributeValue(ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_ACTIVITY_ASYNCHRONOUS)));
}
if (StringUtils.isEmpty(eventDefinition.getSignalRef())) {
model.addProblem("signalEventDefinition does not have required property 'signalRef'", xtr);
}
((Event) parentElement).getEventDefinitions().add(eventDefinition);
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:17,代码来源:SignalEventDefinitionParser.java
示例11: writeAdditionalAttributes
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected void writeAdditionalAttributes(BaseElement element, XMLStreamWriter xtw) throws Exception {
BusinessRuleTask businessRuleTask = (BusinessRuleTask) element;
String inputVariables = convertToDelimitedString(businessRuleTask.getInputVariables());
if (StringUtils.isNotEmpty(inputVariables)) {
writeQualifiedAttribute(ATTRIBUTE_TASK_RULE_VARIABLES_INPUT, inputVariables, xtw);
}
String ruleNames = convertToDelimitedString(businessRuleTask.getRuleNames());
if (StringUtils.isNotEmpty(ruleNames)) {
writeQualifiedAttribute(ATTRIBUTE_TASK_RULE_RULES, ruleNames, xtw);
}
if (StringUtils.isNotEmpty(businessRuleTask.getResultVariableName())) {
writeQualifiedAttribute(ATTRIBUTE_TASK_RULE_RESULT_VARIABLE, businessRuleTask.getResultVariableName(), xtw);
}
if (StringUtils.isNotEmpty(businessRuleTask.getClassName())) {
writeQualifiedAttribute(ATTRIBUTE_TASK_RULE_CLASS, businessRuleTask.getClassName(), xtw);
}
if (businessRuleTask.isExclude()) {
writeQualifiedAttribute(ATTRIBUTE_TASK_RULE_EXCLUDE, ATTRIBUTE_VALUE_TRUE, xtw);
}
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:22,代码来源:BusinessRuleTaskXMLConverter.java
示例12: addExtendProperties
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
public static void addExtendProperties(BaseElement element, ObjectNode propertiesNode) {
List<ExtensionElement> elements = element.getExtensionElements().get(PROPERTY_EXTEND_ELEMENT_NAME);
if (elements != null) {
ObjectNode extendPropertiesNode = objectMapper.createObjectNode();
ArrayNode propertiesArrayNode = objectMapper.createArrayNode();
for (ExtensionElement ee : elements) {
ObjectNode propertyItemNode = objectMapper.createObjectNode();
propertyItemNode.put(PROPERTY_EXTEND_ID, ee.getAttributeValue(null, PROPERTY_EXTEND_ID));
propertyItemNode.put(PROPERTY_EXTEND_NAME, ee.getAttributeValue(null, PROPERTY_EXTEND_NAME));
propertyItemNode.put(PROPERTY_EXTEND_VALUE, ee.getAttributeValue(null, PROPERTY_EXTEND_VALUE));
propertyItemNode.put(PROPERTY_EXTEND_TYPE, ee.getAttributeValue(null, PROPERTY_EXTEND_TYPE));
String expression = ee.getAttributeValue(null, PROPERTY_EXTEND_EXPRESSION);
if (StringUtils.isNotEmpty(expression)) {
propertyItemNode.put(PROPERTY_EXTEND_EXPRESSION, expression);
} else {
propertyItemNode.putNull(PROPERTY_EXTEND_EXPRESSION);
}
propertiesArrayNode.add(propertyItemNode);
}
extendPropertiesNode.set("extendProperties", propertiesArrayNode);
propertiesNode.set(PROPERTY_EXTEND_PROPERTIES, extendPropertiesNode);
}
}
开发者ID:KayuraTeam,项目名称:kayura-activiti,代码行数:30,代码来源:ExtendPropertyUtils.java
示例13: getHandledTypes
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
public Collection<Class<? extends BaseElement>> getHandledTypes() {
Set<Class< ? extends BaseElement>> types = new HashSet<Class<? extends BaseElement>>();
types.add(Process.class);
types.add(UserTask.class);
return types;
}
开发者ID:shawn-gogh,项目名称:myjavacode,代码行数:8,代码来源:MyPostParseHandler.java
示例14: executeParse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected void executeParse(BpmnParse bpmnParse, BaseElement element) {
ProcessDefinitionEntity processDefinitionEntity = bpmnParse.getCurrentProcessDefinition();
List<ActivityImpl> activities = processDefinitionEntity.getActivities();
for (ActivityImpl activity : activities) {
if (activity.getId().equals(element.getId())) {
if (log.isDebugEnabled()) {
log.debug("Enabling data publishing for service task: " + element.getId());
}
activity.addExecutionListener(PvmEvent.EVENTNAME_END, new ServiceTaskCompletionListener());
}
}
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:14,代码来源:ServiceTaskParseHandler.java
示例15: getHandledTypes
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
/**
* Decides which elements to intercept while parsing.
*/
@Override
public Collection<Class<? extends BaseElement>> getHandledTypes() {
List<Class<? extends BaseElement>> elements = new ArrayList<>();
elements.add(UserTask.class);
return elements;
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:11,代码来源:UserTaskParseHandler.java
示例16: parse
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
/**
* Allows to intercept the parsing of given baseElement type
* @param bpmnParse
* @param baseElement
*/
@Override
public void parse(BpmnParse bpmnParse, BaseElement baseElement) {
UserSubstitutionTaskListener listener = new UserSubstitutionTaskListener();
String taskDefinitionKey = baseElement.getId();
TaskDefinition taskDefinition = ((ProcessDefinitionEntity) bpmnParse.getCurrentScope().getProcessDefinition())
.getTaskDefinitions().get(taskDefinitionKey);
if (taskDefinition != null) {
taskDefinition.addTaskListener(TaskListener.EVENTNAME_CREATE, listener);
}
}
开发者ID:wso2,项目名称:carbon-business-process,代码行数:17,代码来源:UserTaskParseHandler.java
示例17: convertXMLToElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected BaseElement convertXMLToElement(XMLStreamReader xtr) throws Exception {
ReceiveTask receiveTask = new ReceiveTask();
BpmnXMLUtil.addXMLLocation(receiveTask, xtr);
parseChildElements(getXMLElementName(), receiveTask, xtr);
return receiveTask;
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:8,代码来源:ReceiveTaskXMLConverter.java
示例18: convertXMLToElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected BaseElement convertXMLToElement(XMLStreamReader xtr) throws Exception {
SequenceFlow sequenceFlow = new SequenceFlow();
BpmnXMLUtil.addXMLLocation(sequenceFlow, xtr);
sequenceFlow.setSourceRef(xtr.getAttributeValue(null, ATTRIBUTE_FLOW_SOURCE_REF));
sequenceFlow.setTargetRef(xtr.getAttributeValue(null, ATTRIBUTE_FLOW_TARGET_REF));
sequenceFlow.setName(xtr.getAttributeValue(null, ATTRIBUTE_NAME));
parseChildElements(getXMLElementName(), sequenceFlow, xtr);
return sequenceFlow;
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:13,代码来源:SequenceFlowXMLConverter.java
示例19: convertXMLToElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected BaseElement convertXMLToElement(XMLStreamReader xtr) throws Exception {
ThrowEvent throwEvent = new ThrowEvent();
BpmnXMLUtil.addXMLLocation(throwEvent, xtr);
parseChildElements(getXMLElementName(), throwEvent, xtr);
return throwEvent;
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:8,代码来源:ThrowEventXMLConverter.java
示例20: convertXMLToElement
import org.activiti.bpmn.model.BaseElement; //导入依赖的package包/类
@Override
protected BaseElement convertXMLToElement(XMLStreamReader xtr) throws Exception {
CallActivity callActivity = new CallActivity();
BpmnXMLUtil.addXMLLocation(callActivity, xtr);
callActivity.setCalledElement(xtr.getAttributeValue(null, ATTRIBUTE_CALL_ACTIVITY_CALLEDELEMENT));
parseChildElements(getXMLElementName(), callActivity, xtr);
return callActivity;
}
开发者ID:springvelocity,项目名称:xbpm5,代码行数:9,代码来源:CallActivityXMLConverter.java
注:本文中的org.activiti.bpmn.model.BaseElement类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论