import java.net.MalformedURLException;
import java.net.URL;
import java.util.List;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.process.ProcessInstance;
import org.kie.api.task.TaskService;
import org.kie.api.task.model.TaskSummary;
import org.kie.remote.client.api.RemoteRuntimeEngineFactory;

public void startProcessAndHandleTaskViaRestRemoteJavaAPI(
	URL instanceUrl, String deploymentId, String user, String password) {

	// The serverRestUrl should contain a URL similar to
	// "http://localhost:8080/business-central/".

	// Set up the factory class with the necessary information to communicate
	// with the REST services.

	RuntimeEngine engine = RemoteRuntimeEngineFactory
		.newRestBuilder()
		.addUrl(instanceUrl)
		.addUserName(user)
		.addPassword(password)
		.addDeploymentId(deploymentId)
		.build();
	KieSession ksession = engine
		.getKieSession();
	TaskService taskService = engine
		.getTaskService();

	// Each operation on a KieSession, TaskService or AuditService (client)
	// instance sends a request for the operation to the server side
	// and waits for the response. If something goes wrong on the server side,
	// the client will throw an exception.


	ProcessInstance processInstance = ksession
		.startProcess("project1.start_and_task_test");

	String taskUserId = user;
	long procId	= processInstance
		.getId();
	taskService	= engine
		.getTaskService();
	List<TaskSummary> tasks = taskService
		.getTasksAssignedAsPotentialOwner(user, "en-UK");
	long taskId = -1;

	for (TaskSummary task : tasks) {
		if (task.getProcessInstanceId() == procId) {
			taskId = task.getId();
		}
	}

	if (taskId == -1) {
		throw new IllegalStateException(
			"Unable to find task for "
			+ user
			+ " in process instance "
			+ procId);
	}

	taskService.start(taskId, taskUserId);
}

import org.kie.api.task.model.OrganizationalEntity;
import org.kie.api.task.model.Task;

Task task = taskService.getTaskById(TASK_ID);
List<OrganizationalEntity> org = task.getPeopleAssignments().getPotentialOwners();

for (OrganizationalEntity ent : org) {
  System.out.println("org: " + ent.getId());
}

RuntimeEngine engine = RemoteRuntimeEngineFactory
	.newRestBuilder()
	.addUrl(instanceUrl)
	.addUserName(user)
	.addPassword(password)
	.build();

	// This call does not require the deployment ID and ends successfully:

	engine.getTaskService().claim(23l, "user");

	// This code throws a "MissingRequiredInfoException" because the
	// deployment ID is required:

	engine.getKieSession().startProcess("org.test.process");

Example Usage

import org.kie.api.runtime.KieSession;
import org.kie.api.task.TaskService;
import org.kie.api.runtime.process.ProcessInstance;
import org.kie.services.client.api.RemoteJmsRuntimeEngineFactory;
import org.kie.services.client.api.command.RemoteRuntimeEngine;

public void javaRemoteApiJmsExample
	(String deploymentId, Long processInstanceId, String user, String password) {

	// Create a factory class with all the values:
	RemoteJmsRuntimeEngineFactory jmsRuntimeFactory = RemoteRuntimeEngineFactory
		.newJmsBuilder()
		.addDeploymentId(deploymentId)
		.addProcessInstanceId(processInstanceId)
		.addUserName(user)
		.addPassword(password)
		.addRemoteInitialContext(remoteInitialContext)
		.addTimeout(3)
		.addExtraJaxbClasses(MyType.class)
		.useSsl(false)
		.build();

	RemoteRuntimeEngine engine = jmsRuntimeFactory.newRuntimeEngine();

	// Create KieSession and TaskService instances and use them:
	KieSession ksession = engine.getKieSession();
	TaskService taskService = engine.getTaskService();

	// Each operation on a KieSession, TaskService or AuditService (client) instance
	// sends a request for the operation to the server side and waits for the response.
	// If something goes wrong on the server side, the client will throw an exception.
	ProcessInstance processInstance
		= ksession.startProcess("com.burns.reactor.maintenance.cycle");
	long procId = processInstance.getId();

	String taskUserId = user;
	taskService = engine.getTaskService();
	List<TaskSummary> tasks = taskService
		.getTasksAssignedAsPotentialOwner(user, "en-UK");

	long taskId = -1;
	for (TaskSummary task : tasks) {
		if (task.getProcessInstanceId() == procId) {
			taskId = task.getId();
		}
	}

	if (taskId == -1) {
		throw new IllegalStateException
			("Unable to find task for "
			+ user 
			+ " in process instance " 
			+ procId);
	}

	taskService.start(taskId, taskUserId);
}

Configuration using an InitialContext instance

private InitialContext getRemoteJbossInitialContext(URL url, String user, String password) {

	Properties initialProps = new Properties();
	initialProps.setProperty
		(InitialContext.INITIAL_CONTEXT_FACTORY,
		"org.jboss.naming.remote.client.InitialContextFactory");
	String jbossServerHostName = url.getHost();
	initialProps.setProperty
		(InitialContext.PROVIDER_URL, "remote://"+ jbossServerHostName + ":4447");
	initialProps.setProperty(InitialContext.SECURITY_PRINCIPAL, user);
	initialProps.setProperty(InitialContext.SECURITY_CREDENTIALS, password);

	for (Object keyObj : initialProps.keySet()) {
		String key = (String) keyObj;
		System.setProperty(key, (String) initialProps.get(key));
	}
	
	try {
		return new InitialContext(initialProps);
	} catch (NamingException e) {
		throw new RemoteCommunicationException
			("Unable to create " + InitialContext.class.getSimpleName(), e);
	}
}