concrete node instance
+ * @param container parent node
+ */
+public interface NodeBuilder, P extends NodeContainerBuilder> {
+
+ /**
+ * Method to notify that definition of this node is done
+ *
+ * @return container parent node
+ */
+ P done();
+
+ T name(String name);
+
+ T setMetadata(String key, Object value);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/NodeContainerBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/NodeContainerBuilder.java
new file mode 100644
index 00000000000..29e54f5f73a
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/NodeContainerBuilder.java
@@ -0,0 +1,73 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+/**
+ * Include operations to define a container node.
+ * As it name indicates, a container node contains nodes (a process is also a container node), so this class defines all methods to create children nodes.
+ * A container node also holds variables, exception handlers and establish connections between nodes.
+ *
+ * @param Concrete container node
+ * @param Parent container node
+ */
+public interface NodeContainerBuilder, P extends NodeContainerBuilder> extends NodeBuilder {
+
+ StartNodeBuilder startNode(long id);
+
+ EndNodeBuilder endNode(long id);
+
+ ActionNodeBuilder actionNode(long id);
+
+ MilestoneNodeBuilder milestoneNode(long id);
+
+ TimerNodeBuilder timerNode(long id);
+
+ HumanTaskNodeBuilder humanTaskNode(long id);
+
+ SubProcessNodeBuilder subProcessNode(long id);
+
+ SplitNodeBuilder splitNode(long id);
+
+ JoinNodeBuilder joinNode(long id);
+
+ RuleSetNodeBuilder ruleSetNode(long id);
+
+ FaultNodeBuilder faultNode(long id);
+
+ EventNodeBuilder eventNode(long id);
+
+ BoundaryEventNodeBuilder boundaryEventNode(long id);
+
+ CompositeNodeBuilder compositeNode(long id);
+
+ ForEachNodeBuilder forEachNode(long id);
+
+ DynamicNodeBuilder dynamicNode(long id);
+
+ WorkItemNodeBuilder workItemNode(long id);
+
+ T exceptionHandler(Class exceptionClass, Dialect dialect, String code);
+
+ T connection(long fromId, long toId);
+
+ /**
+ * Adds a variable to this container
+ */
+ T variable(Variable variable);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilder.java
new file mode 100644
index 00000000000..09fc9fc0c91
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilder.java
@@ -0,0 +1,56 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+import java.util.Collection;
+import java.util.Map;
+
+import org.kie.api.definition.process.Process;
+
+/**
+ * Builder that contains methods to create a process definition.
+ *
+ * @see ProcessBuilderFactory
+ */
+public interface ProcessBuilder extends NodeContainerBuilder {
+
+ ProcessBuilder dynamic(boolean dynamic);
+
+ ProcessBuilder version(String version);
+
+ ProcessBuilder packageName(String packageName);
+
+ ProcessBuilder imports(Collection imports);
+
+ ProcessBuilder functionImports(Collection functionImports);
+
+ ProcessBuilder globals(Map globals);
+
+ ProcessBuilder global(String name, String type);
+
+ ProcessBuilder swimlane(String name);
+
+ /**
+ * Validates and returns process definition.
+ * Should be invoked after all other method calls.
+ *
+ * @return validated process definition
+ */
+ Process build();
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactories.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactories.java
new file mode 100644
index 00000000000..9cecb1226a7
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactories.java
@@ -0,0 +1,50 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+import org.slf4j.LoggerFactory;
+
+/**
+ * Holds an utility method to retrieve ProcessBuilderFactory default instance.
+ * Default instance returned by get method can be modified by setting property "org.jbpm.processBuilder.factoryClass"
+ * Value should be full class name of a ProcessBuilderFactory implementation that contains a default public constructor
+ */
+public class ProcessBuilderFactories {
+
+ private ProcessBuilderFactories() {
+ }
+
+ private static ProcessBuilderFactory instance;
+
+ public static synchronized ProcessBuilderFactory get() {
+ if (instance == null) {
+ try {
+ instance =
+ Class.forName(System.getProperty("org.jbpm.processBuilder.factoryClass",
+ "org.jbpm.ruleflow.core.RuleFlowProcessFactoryBuilder"))
+ .asSubclass(ProcessBuilderFactory.class)
+ .newInstance();
+ } catch (ReflectiveOperationException e) {
+ LoggerFactory.getLogger(ProcessBuilderFactories.class).error("Unable to instance ProcessBuilderFactory", e);
+ throw new IllegalStateException(e);
+ }
+ }
+ return instance;
+ }
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactory.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactory.java
new file mode 100644
index 00000000000..acaeaba9166
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/ProcessBuilderFactory.java
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+import org.kie.api.definition.process.Process;
+
+/**
+ * Factory to create process builder instance.
+ * It is also a convenient place holder for additional utility methods
+ */
+public interface ProcessBuilderFactory {
+
+ /**
+ * Returns a ProcessBuilder that can be used to create a process definition
+ *
+ * @param processId the unique id of the process being defined
+ * @return builder instance to create process definition
+ */
+ ProcessBuilder processBuilder(String processId);
+
+ /**
+ * Converts process definition into an array of bytes.
+ * Typically this array will be converted to a Resource for a KIE base
+ *
+ * @param builder process definition to be converted to byte[]
+ * @return byte[] containing process definition
+ */
+ byte[] toBytes(Process builder);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/RuleSetNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/RuleSetNodeBuilder.java
new file mode 100644
index 00000000000..ce54d461dc8
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/RuleSetNodeBuilder.java
@@ -0,0 +1,24 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface RuleSetNodeBuilder> extends NodeBuilder, T>, TimerOperations, T> {
+
+ RuleSetNodeBuilder ruleFlowGroup(String ruleFlowGroup);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SplitNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SplitNodeBuilder.java
new file mode 100644
index 00000000000..0b75e496eba
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SplitNodeBuilder.java
@@ -0,0 +1,27 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface SplitNodeBuilder> extends NodeBuilder, T> {
+
+ SplitNodeBuilder type(int type);
+
+ SplitNodeBuilder constraint(long toNodeId, String name, String type, Dialect dialect, String constraint, int priority);
+
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/StartNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/StartNodeBuilder.java
new file mode 100644
index 00000000000..a4c629516fc
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/StartNodeBuilder.java
@@ -0,0 +1,23 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface StartNodeBuilder> extends NodeBuilder, T> {
+ // TODO event triggers?
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SubProcessNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SubProcessNodeBuilder.java
new file mode 100644
index 00000000000..3311e709b33
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/SubProcessNodeBuilder.java
@@ -0,0 +1,33 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface SubProcessNodeBuilder> extends NodeBuilder, T>, HumanNodeOperations, T> {
+
+ SubProcessNodeBuilder processId(final String processId);
+
+ SubProcessNodeBuilder waitForCompletion(boolean waitForCompletion);
+
+ SubProcessNodeBuilder inMapping(String parameterName, String variableName);
+
+ SubProcessNodeBuilder outMapping(String parameterName, String variableName);
+
+ SubProcessNodeBuilder independent(boolean independent);
+
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerNodeBuilder.java
new file mode 100644
index 00000000000..9999c288df6
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerNodeBuilder.java
@@ -0,0 +1,26 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface TimerNodeBuilder> extends NodeBuilder, T> {
+
+ TimerNodeBuilder delay(String delay);
+
+ TimerNodeBuilder period(String period);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerOperations.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerOperations.java
new file mode 100644
index 00000000000..5711e62e9b0
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/TimerOperations.java
@@ -0,0 +1,24 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+interface TimerOperations, P extends NodeContainerBuilder> {
+
+ T timer(String delay, String period, Dialect dialect, String action);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/Variable.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/Variable.java
new file mode 100644
index 00000000000..61c1dbd5c93
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/Variable.java
@@ -0,0 +1,89 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Builder pattern like class used to build a variable.
+ * A variable requires a name and a data type.
+ * Value and metadata are optional.
+ * Usage:
+ *
+ *
+ * Variable.var("test",String.class)
+ * .value("example value")
+ * .metadata("readOnly",true).
+ * .metadata("required",false)
+ *
+ *
+ * @param data type of the variable
+ * @see NodeContainerBuilder#variable(Variable)
+ */
+public class Variable {
+
+ private String name;
+ private T value;
+ private Class type;
+ private Map metadata;
+
+ private Variable(String name, Class type) {
+ this.name = name;
+ this.type = type;
+ }
+
+ public static Variable var(String name, Class type) {
+ return new Variable<>(name, type);
+ }
+
+ public Variable value(T value) {
+ this.value = value;
+ return this;
+ }
+
+ public Variable metadata(String key, Object value) {
+ if (metadata == null) {
+ metadata = new HashMap<>();
+ }
+ metadata.put(key, value);
+ return this;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public T getValue() {
+ return value;
+ }
+
+ public Class getType() {
+ return type;
+ }
+
+ public Map getMetadata() {
+ return metadata;
+ }
+
+ @Override
+ public String toString() {
+ return "Variable [name=" + name + ", value=" + value + ", type=" + type + ", metadata=" + metadata + "]";
+ }
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/WorkItemNodeBuilder.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/WorkItemNodeBuilder.java
new file mode 100644
index 00000000000..c3e92ff5a8f
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/WorkItemNodeBuilder.java
@@ -0,0 +1,34 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.fluent;
+
+public interface WorkItemNodeBuilder> extends NodeBuilder, T>, HumanNodeOperations, T> {
+
+ WorkItemNodeBuilder waitForCompletion(boolean waitForCompletion);
+
+ WorkItemNodeBuilder inMapping(String parameterName, String variableName);
+
+ WorkItemNodeBuilder outMapping(String parameterName, String variableName);
+
+ WorkItemNodeBuilder workName(String name);
+
+ WorkItemNodeBuilder workParameter(String name, Object value);
+
+ WorkItemNodeBuilder workParameterDefinition(String name, Class type);
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/package-info.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/package-info.java
new file mode 100644
index 00000000000..ef6b68e86ee
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/fluent/package-info.java
@@ -0,0 +1,90 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+/**
+ * Process Fluent API allows programmer to build an in memory representation of a bpmn file.
+ * This information can later be used to build a KIE resource and execute the process .
+ * Typical use of fluent API will be:
+ * Build a process definition that prints action string in console using ProcessBuilder several methods
+ *
+ *
+ * // Obtain default ProcessBuilderFactory
+ * ProcessBuilderFactory factory = ProcessBuilderFactories.get();
+ * ProcessBuilderFactory factory = ProcessBuilderFactories.get();
+ * Process process =
+ * // Create process builder
+ * factory.processBuilder(processId)
+ * // package and name
+ * .packageName("org.jbpm")
+ * .name("My process")
+ * // start node
+ * .startNode(1).name("Start").done()
+ * // Add variable of type string
+ * .variable(var("pepe", String.class))
+ * // Add exception handler
+ * .exceptionHandler(IllegalArgumentException.class, Dialect.JAVA, "System.out.println(\"Exception\");")
+ * // script node in Java language that prints "action"
+ * .actionNode(2).name("Action")
+ * .action(Dialect.JAVA,
+ * "System.out.println(\"Action\");")
+ * .done()
+ * // end node
+ * .endNode(3).name("End").done()
+ * // connections
+ * .connection(1,
+ * 2)
+ * .connection(2,
+ * 3)
+ * .build();
+ *
+ *
+ * Create a resource from the process definition (process needs to be converted to byte[] using ProcessBuilderFactory)
+ *
+ *
+ * // Build resource from ProcessBuilder
+ * KieResources resources = ServiceRegistry.getInstance().get(KieResources.class);
+ * Resource res = resources
+ * .newByteArrayResource(factory.toBytes(process))
+ * .setSourcePath("/tmp/processFactory.bpmn2"); // source path or target path must be set to be added into kbase
+ *
+ *
+ * Build kie base from this resource using KIE API
+ *
+ *
+ * KieServices ks = KieServices.Factory.get();
+ * KieRepository kr = ks.getRepository();
+ * KieFileSystem kfs = ks.newKieFileSystem();
+ * kfs.write(res);
+ * KieBuilder kb = ks.newKieBuilder(kfs);
+ * kb.buildAll(); // kieModule is automatically deployed to KieRepository if successfully built.
+ * KieContainer kContainer = ks.newKieContainer(kr.getDefaultReleaseId());
+ * KieBase kbase = kContainer.getKieBase();
+ *
+ *
+ * Create kie session using this kie base and execute the process
+ *
+ *
+ // Create kie session
+ KieSessionConfiguration conf = ...;
+ Environment env = ....;
+ KieSession ksession = kbase.newKieSession(conf,env);
+ // execute process using same process id that was used to obtain ProcessBuilder instance
+ ksession.startProcess(processId);
+ *
+ */
+package org.kie.api.fluent;
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/DataTransformer.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/DataTransformer.java
new file mode 100644
index 00000000000..6f71e2d80fe
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/DataTransformer.java
@@ -0,0 +1,55 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.runtime.process;
+
+import java.util.Map;
+
+/**
+ * Data transformation capabilities used by data input and data output transformation
+ * as part of BPMN2 process definition. It allows plugable implementations.
+ *
+ */
+public interface DataTransformer {
+
+ /**
+ * Compiles given expression into reusable unit. This is optional operation and in case
+ * it's not supported by given transformed it should return the same expression that was
+ * given in the input. If compilation is supported a compiled instance of the expression
+ * should be returned.
+ *
+ * @param expression language specific expression
+ * @param parameters parameters e.g. imports defined in the process
+ * @return compiled expression instance or same as given as argument expression
+ * @throws RuntimeException in case of unexpected errors during compilation
+ */
+ public Object compile(String expression, Map parameters);
+
+ /**
+ * Transforms the given expression object (might be compiled expression) using
+ * parameters as contextual information (aka bindings) used during
+ * evaluation of the expression.
+ *
+ * @param expression expression to evaluate
+ * @param parameters binding parameters
+ * @return result of the evaluation
+ * @throws RuntimeException in case of unexpected errors during evaluation of the expression
+ */
+ public Object transform(Object expression, Map parameters);
+
+}
diff --git a/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/ProcessWorkItemHandlerException.java b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/ProcessWorkItemHandlerException.java
new file mode 100644
index 00000000000..9c10c374d9b
--- /dev/null
+++ b/jbpm/jbpm-flow-api/src/main/java/org/kie/api/runtime/process/ProcessWorkItemHandlerException.java
@@ -0,0 +1,75 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.kie.api.runtime.process;
+
+public class ProcessWorkItemHandlerException extends RuntimeException {
+
+ private static final long serialVersionUID = 328927887939759492L;
+
+ private static final int MAX_NUMBER_OF_RETRIES = 3;
+
+ public enum HandlingStrategy {
+ RETRY,
+ COMPLETE,
+ ABORT,
+ RETHROW
+ }
+
+ private String processId;
+ private HandlingStrategy strategy;
+ private int retries;
+
+ public ProcessWorkItemHandlerException(String processId, String strategy, Throwable cause) {
+ this(processId, HandlingStrategy.valueOf(strategy), cause, MAX_NUMBER_OF_RETRIES);
+ }
+
+ public ProcessWorkItemHandlerException(String processId, String strategy, Throwable cause, int retries) {
+ this(processId, HandlingStrategy.valueOf(strategy), cause, retries);
+ }
+
+ public ProcessWorkItemHandlerException(String processId, HandlingStrategy strategy, Throwable cause) {
+ this(processId, strategy, cause, MAX_NUMBER_OF_RETRIES);
+ }
+
+ public ProcessWorkItemHandlerException(String processId, HandlingStrategy strategy, Throwable cause, int retries) {
+ super(cause);
+ this.processId = processId;
+ this.strategy = strategy;
+ this.retries = retries;
+ if (processId == null || strategy == null) {
+ throw new IllegalArgumentException("Process id and strategy are required");
+ }
+ if (retries < 0) {
+ throw new IllegalArgumentException("Retries cannot be negative");
+ }
+ }
+
+ public String getProcessId() {
+ return processId;
+ }
+
+ public HandlingStrategy getStrategy() {
+ return strategy;
+ }
+
+ public int getRetries() {
+ return retries;
+ }
+
+}
diff --git a/jbpm/jbpm-flow/pom.xml b/jbpm/jbpm-flow/pom.xml
index d0fc15edb26..0c63fafcb38 100755
--- a/jbpm/jbpm-flow/pom.xml
+++ b/jbpm/jbpm-flow/pom.xml
@@ -49,10 +49,21 @@
pom
import