src/org/apache/kandula/ba/AtomicBusinessActivity.java

package org.apache.kandula.ba;


import org.apache.kandula.Constants;
import org.apache.kandula.context.impl.BAActivityContext;
import org.apache.kandula.coordinator.Coordinator;
import org.apache.kandula.coordinator.ba.BACoordinator;
import org.apache.kandula.faults.AbstractKandulaException;

public class AtomicBusinessActivity extends BusinessActivity{
	
	public AtomicBusinessActivity(long expires ) throws AbstractKandulaException {
		Coordinator coordinator = new Coordinator();
		context = (BAActivityContext)coordinator.createCoordinationContext(Constants.WS_BA_ATOMIC,
				expires);
	}
	
	public void closeActivity() throws AbstractKandulaException
	{
		BACoordinator atomicBACoordinator = new BACoordinator();
		atomicBACoordinator.closeAllOperation(context);
	}
	
	public void compensateActivity() throws AbstractKandulaException
	{
		BACoordinator atomicBACoordinator = new BACoordinator();
		atomicBACoordinator.compensateAllOperation(context);
	}
}