Transactions managed programmatically

sergio13971 — Wed, 20 Nov 2013 20:33:22 GMT

Hello everyone, I'm novel in activiti and I wish to manage the execution of services's methods like TaskService (createAttachment(… , setVariables(… ) transactionally, e.g. I want to add some attachments, following execute setVariables(..), but if one of the attachments fail make a rollback of every

Re: Transactions managed programmatically

sergio13971 — Thu, 21 Nov 2013 03:37:25 GMT

…any idea? I'm very lost in this thing, I've read a lot but unsuccessful. I'm trying to start a transaction from processEngineConfiguration, recovering the TransactionManager and calling begin() method, but it looks like operations disregard this transaction and the activities are processed alone in a different transaction. I'll really appreciate some help!!

Best regards,

Re: Transactions managed programmatically

martin_grofcik — Thu, 21 Nov 2013 07:32:34 GMT

Hello Sergio.

if
http://www.activiti.org/userguide/#bpmnConcurrencyAndTransactions
is not enough to explain transactions, you can debug some task behavior implementation. When transaction is initiated, committed, rolled back.

Martin

Re: Transactions managed programmatically

sergio13971 — Thu, 21 Nov 2013 14:25:40 GMT

…Martin, thanks for your reply, I read what you recommend me, but, I understand this is about the steps in a workflow, but I want to do is in one transaction add differents attachments to a task, some comments to the same task, and if all of them end successfully update the task, in other case rollback everything done before exception was triggered. All of this made programmatically.

The code here :

    @SuppressWarnings("unchecked")
    public static HashMap<String, Object> updateTaskById(String userId, String taskId, String processInstanceId, HashMap<String, Object> params) throws BussinesException, IOException, SQLException, NotSupportedException, SystemException, NamingException
    {
        HashMap<String, Object> result = new HashMap<String, Object>();
        String consultedUser = (String) params.get("consultedUser");
        WorkflowService.getIdentityService().setAuthenticatedUserId(consultedUser != null && consultedUser.trim().length() > 0 ? consultedUser : userId);
        HashMap<String, String> documentsData = (HashMap<String, String>) params.get("documentsData");
        HashMap<String, Object> variables = (HashMap<String, Object>) params.get("variables");

        System.out.println("VARIABLES=>" + variables);
        String dirPath = null;
        String[] documents = ((String) variables.get("document.documents")).split(";");
        for (String doc : documents)
        {
            String documentPath = documentsData.get(doc + ".path");
            String documentType = documentsData.get(doc + ".contetType");
            String attachmentId;
            if (dirPath == null && documentPath != null && documentPath.length() > 0)
            {
                dirPath = documentPath.substring(0, documentPath.lastIndexOf("/") + 1);
            }

            if (documentPath != null && documentPath.length() > 0)
            {
                if (dirPath == null)
                {
                    dirPath = documentPath.substring(0, documentPath.lastIndexOf("/") + 1);
                }
                File file = new File(documentPath);
                String docKey;
                attachmentId = (String) variables.get(docKey = "document." + doc + ".value");
                if (file.exists())
                {
                    /*If some addAttachment fail, perform a rollback */
                    variables.put(docKey, addAttachment(documentType, taskId, processInstanceId, file.getName(), "", new FileInputStream(file)));
                    if (attachmentId != null && attachmentId.length() > 0)
                    {
                        removeAttachmentById(attachmentId);
                    }
                }
                else
                {
                    throw new BussinesException("No se encontro el Archivo");
                }
            }
        }

        ArrayList<HashMap<String, Object>> comments = (ArrayList<HashMap<String, Object>>) params.get("comments");
        for (HashMap<String, Object> comment : comments)
        {
            String fullMessage = (String) comment.get("fullMessage");
            if (comment.get("id") == null && fullMessage != null)
            {
                System.out.println("Insert Comment=>" + comment);
                /*If some addComment fail, perform a rollback */
                WorkflowService.getTaskService().addComment(taskId, processInstanceId, fullMessage);
            }
        }

        if (dirPath != null)
        {
            FileUtils.cleanDirectory(new File(dirPath));
        }
        updateTaskParams(taskId, variables);
        /*If everything goes fine perform commit */
        result.put("variables", variables);
        System.out.println("VARIABLES=>" + variables);
        return result;
    }

Thanks for your help.

Re: Transactions managed programmatically

pmsevestre — Fri, 22 Nov 2013 01:02:55 GMT

I think the following forum question can help you:

http://forums.activiti.org/content/external-application-transaction-management

Basically, you need a transaction manager to handle the case where multiple activiti api calls must be handled as a single UoW.

topic Transactions managed programmatically in Alfresco Archive

Transactions managed programmatically

Re: Transactions managed programmatically

Re: Transactions managed programmatically

Re: Transactions managed programmatically

Re: Transactions managed programmatically