import org.activiti.engine.delegate.event.ActivitiEventType; //导入依赖的package包/类
@Override
public List<ActivityDefinition> nextActivities(String userId, final String taskId, final Map<String, Object> variables) {

    new TransactionTemplate(transactionManager).execute(new TransactionCallback<Object>() {
        @Override
        public Object doInTransaction(TransactionStatus status) {
            FollowActivityEventListener activityEventListener = new FollowActivityEventListener();
            runtimeService.addEventListener(activityEventListener, ActivitiEventType.ACTIVITY_STARTED);
            taskService.complete(taskId,variables);
            runtimeService.removeEventListener(activityEventListener);
            status.setRollbackOnly();
            return null;
        }
    });

    return FollowActivityContext.getActivitys();
}
 

import org.activiti.engine.delegate.event.ActivitiEventType; //导入依赖的package包/类
public void dispatchPackageUpdatedEvent(Object variableValue, String taskId, String executionId, String processInstanceId, String processDefinitionId)
{
    runtimeService.dispatchEvent(
       ActivitiEventBuilder.createVariableEvent(ActivitiEventType.VARIABLE_UPDATED, WorkflowNotificationUtils.PROP_PACKAGE,
                        variableValue, new ScriptNodeVariableType(), 
                        taskId, executionId, processInstanceId, processDefinitionId));
}
 

import org.activiti.engine.delegate.event.ActivitiEventType; //导入依赖的package包/类
public Object execute(CommandContext commandContext) {
    TaskEntity taskEntity = commandContext.getTaskEntityManager()
            .findTaskById(taskId);

    if (variables != null) {
        taskEntity.setExecutionVariables(variables);
    }

    boolean localScope = false;

    if ((taskEntity.getDelegationState() != null)
            && taskEntity.getDelegationState().equals(
                    DelegationState.PENDING)) {
        throw new ActivitiException(
                "A delegated task cannot be completed, but should be resolved instead.");
    }

    taskEntity.fireEvent(TaskListener.EVENTNAME_COMPLETE);

    if ((Authentication.getAuthenticatedUserId() != null)
            && (taskEntity.getProcessInstanceId() != null)) {
        taskEntity.getProcessInstance().involveUser(
                Authentication.getAuthenticatedUserId(),
                IdentityLinkType.PARTICIPANT);
    }

    if (Context.getProcessEngineConfiguration().getEventDispatcher()
            .isEnabled()) {
        Context.getProcessEngineConfiguration()
                .getEventDispatcher()
                .dispatchEvent(
                        ActivitiEventBuilder
                                .createEntityWithVariablesEvent(
                                        ActivitiEventType.TASK_COMPLETED,
                                        taskEntity, variables, localScope));
    }

    Context.getCommandContext().getTaskEntityManager()
            .deleteTask(taskEntity, comment, false);

    if (taskEntity.getExecutionId() != null) {
        ExecutionEntity execution = taskEntity.getExecution();
        execution.removeTask(taskEntity);

        try {
            Context.setExecutionContext(execution);
            execution.signal(null, null);
        } finally {
            Context.removeExecutionContext();
        }
    }

    return null;
}