You are viewing a plain text version of this content. The canonical link for it is here.
Posted to kandula-dev@ws.apache.org by th...@apache.org on 2007/01/29 14:31:46 UTC

svn commit: r501042 - /webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java

Author: thilina
Date: Mon Jan 29 05:31:45 2007
New Revision: 501042

URL: http://svn.apache.org/viewvc?view=rev&rev=501042
Log:
hmm... ws-ba stuff are troubling me...

Modified:
    webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java

Modified: webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java?view=diff&rev=501042&r1=501041&r2=501042
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/coordinator/ba/BACoordinator.java Mon Jan 29 05:31:45 2007
@@ -17,24 +17,10 @@
 package org.apache.kandula.coordinator.ba;
 
 
-import org.apache.axis2.AxisFault;
 import org.apache.axis2.addressing.EndpointReference;
-import org.apache.kandula.Status;
-import org.apache.kandula.Status.BACoordinatorStatus;
 import org.apache.kandula.context.AbstractContext;
-import org.apache.kandula.context.impl.BAActivityContext;
 import org.apache.kandula.coordinator.Registerable;
 import org.apache.kandula.faults.AbstractKandulaException;
-import org.apache.kandula.faults.InvalidStateException;
-import org.apache.kandula.faults.KandulaGeneralException;
-import org.apache.kandula.wsba.BACoordinatorCompletionParticipantServiceStub;
-import org.apache.kandula.wsba.BAParticipantCompletionParticipantServiceStub;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Cancel;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Close;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Compensate;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Complete;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Exited;
-import org.oasis_open.docs.ws_tx.wsba._2006._06.Failed;
 
 /**
  * @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
@@ -68,25 +54,26 @@
 	public EndpointReference register(AbstractContext context, String protocol,
 			EndpointReference participantEPR)throws AbstractKandulaException 
 	{
-		BAActivityContext baContext = (BAActivityContext) context;
-		baContext.lock();
-		int coordinatorStatus = baContext.getStatus();
-		if(coordinatorStatus ==(BACoordinatorStatus.STATUS_CLOSING))
-		{
-			baContext.unlock();
-			throw new InvalidStateException ("Coordinator is in closing status ");
-		}else if(coordinatorStatus ==(BACoordinatorStatus.STATUS_COMPENSATING))
-		{
-			baContext.unlock();
-			throw new InvalidStateException ("Coordinator is in compensating status ");
-		}
-		else
-		{
-			EndpointReference epr = baContext.addParticipant(participantEPR,
-					protocol);
-			baContext.unlock();
-			return epr;
-		}
+//		BAActivityContext baContext = (BAActivityContext) context;
+//		baContext.lock();
+//		int coordinatorStatus = baContext.getStatus();
+//		if(coordinatorStatus ==(BACoordinatorStatus.STATUS_CLOSING))
+//		{
+//			baContext.unlock();
+//			throw new InvalidStateException ("Coordinator is in closing status ");
+//		}else if(coordinatorStatus ==(BACoordinatorStatus.STATUS_COMPENSATING))
+//		{
+//			baContext.unlock();
+//			throw new InvalidStateException ("Coordinator is in compensating status ");
+//		}
+//		else
+//		{
+//			EndpointReference epr = baContext.addParticipant(participantEPR,
+//					protocol);
+//			baContext.unlock();
+//			return epr;
+//		}
+		return null;
 	}
 	
 	/**



---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org