You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by da...@apache.org on 2005/12/29 13:14:37 UTC
svn commit: r359777 -
/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java
Author: dasarath
Date: Thu Dec 29 04:14:35 2005
New Revision: 359777
URL: http://svn.apache.org/viewcvs?rev=359777&view=rev
Log: (empty)
Modified:
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java
Modified: webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java?rev=359777&r1=359776&r2=359777&view=diff
==============================================================================
--- webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java (original)
+++ webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/ATCoordinatorImpl.java Thu Dec 29 04:14:35 2005
@@ -58,7 +58,7 @@
participants2PC[i] = Collections.synchronizedMap(new HashMap());
}
- public synchronized EndpointReference register(String prot,
+ public EndpointReference register(String prot,
EndpointReference pps) throws InvalidCoordinationProtocolException {
if (!(status == AT2PCStatus.ACTIVE || status == AT2PCStatus.PREPARING_VOLATILE))
throw new IllegalStateException();
@@ -399,6 +399,10 @@
public synchronized void rollbackOperation(Notification parameters)
throws RemoteException {
+ rollback();
+ }
+
+ public synchronized void timeout() {
rollback();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org