Behavior Execution onCommit and not beforeCommit

xian — Wed, 17 Nov 2010 14:56:05 GMT

HiI have a policy that detects node creation and passes the reference to another thread for processing. The problem is that the policies behaviour is executed before the transaction has finished committing and so the worker thread can't 'see' the new node in its transaction if it begins execution so

Re: Behavior Execution onCommit and not beforeCommit

mrogers — Wed, 17 Nov 2010 20:48:59 GMT

The action service allows you to queue actions that will run post commit, it underpins the RuleService. That's probably your best bet.

I don't think a policy will help, although you could register a TransactionListener to listen for the commit.

Re: Behavior Execution onCommit and not beforeCommit

xian — Thu, 18 Nov 2010 14:19:41 GMT

I had quite a bit of help on email too and have implemented the TransactionListener. It's quite simple and works well.

You should look at the "SDK Custom Aspect" in the SDK, which uses a TransactionListenerAdapter to execute stuff in its afterCommit() method so that it is effectively executed after the transaction has been committed.

The working code is below. The Aggregator is just another bean that starts a thread to do the work.


package com.culturenetcymru.unc;

import com.culturenetcymru.unc.senders.Aggregator;
import org.alfresco.repo.node.NodeServicePolicies;
import org.alfresco.repo.policy.Behaviour.NotificationFrequency;
import org.alfresco.repo.policy.JavaBehaviour;
import org.alfresco.repo.policy.PolicyComponent;
import org.alfresco.repo.transaction.AlfrescoTransactionSupport;
import org.alfresco.repo.transaction.TransactionListenerAdapter;
import org.alfresco.service.cmr.repository.ChildAssociationRef;
import org.alfresco.service.cmr.repository.NodeRef;

/**
 *
 * @author Xian Stannard
 */
public class SendStatePolicy extends TransactionListenerAdapter implements NodeServicePolicies.OnCreateNodePolicy {
   public static final String NODE_KEY = SendStatePolicy.class.getName() + ".node";
   private PolicyComponent policyComponent;
   private Aggregator sender;


   public void setPolicyComponent(PolicyComponent policyComponent) {
      this.policyComponent = policyComponent;
   }

   public void setSender(Aggregator sender) {
      this.sender = sender;
   }

   public void init() {
      policyComponent.bindClassBehaviour(
         NodeServicePolicies.OnCreateNodePolicy.QNAME,
         UncModel.TYPE_STATE,
         new JavaBehaviour(
            this,
            "onCreateNode",
            NotificationFrequency.TRANSACTION_COMMIT
         )
      );
   }

   public void onCreateNode(ChildAssociationRef car) {
      AlfrescoTransactionSupport.bindListener(this);
      AlfrescoTransactionSupport.bindResource(NODE_KEY, car.getChildRef());
   }

   @Override
   public void afterCommit() {
      NodeRef node = AlfrescoTransactionSupport.getResource(SendStatePolicy.NODE_KEY);
      if(node != null)
         sender.queueItem(node, false);
   }
}
‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

topic Re: Behavior Execution onCommit and not beforeCommit in Alfresco Archive

Behavior Execution onCommit and not beforeCommit

Re: Behavior Execution onCommit and not beforeCommit

Re: Behavior Execution onCommit and not beforeCommit