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 da...@apache.org on 2006/01/02 20:13:35 UTC
svn commit: r365398 - in
/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator:
Coordinator.java CoordinatorImpl.java
Author: dasarath
Date: Mon Jan 2 11:13:33 2006
New Revision: 365398
URL: http://svn.apache.org/viewcvs?rev=365398&view=rev
Log: (empty)
Modified:
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/Coordinator.java
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/CoordinatorImpl.java
Modified: webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/Coordinator.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/Coordinator.java?rev=365398&r1=365397&r2=365398&view=diff
==============================================================================
--- webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/Coordinator.java (original)
+++ webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/Coordinator.java Mon Jan 2 11:13:33 2006
@@ -4,6 +4,9 @@
*/
package org.apache.ws.transaction.coordinator;
+import javax.xml.namespace.QName;
+
+import org.apache.axis.AxisFault;
import org.apache.ws.transaction.utility.Callback;
import org.apache.ws.transaction.wscoor.RegistrationPortTypeRPC;
@@ -12,7 +15,25 @@
*
*/
public interface Coordinator extends RegistrationPortTypeRPC, Callback {
+
+ AxisFault ALREADY_REGISTERED_SOAP_FAULT = new AxisFault(
+ new QName("http://schemas.xmlsoap.org/ws/2004/10/wscoor",
+ "AlreadyRegistered"),
+ "The participant has already registered for the same protocol.",
+ null, null);
+
+ AxisFault INVALID_PROTOCOL_SOAP_FAULT = new AxisFault(new QName(
+ "http://schemas.xmlsoap.org/ws/2004/10/wscoor", "InvalidProtocol"),
+ "The protocol is invalid or is not supported by the coordinator.",
+ null, null);
+
+ AxisFault INVALID_STATE_SOAP_FAULT = new AxisFault(new QName(
+ "http://schemas.xmlsoap.org/ws/2004/10/wscoor", "InvalidState"),
+ "The message was invalid for the current state of the activity.",
+ null, null);
+
String getID();
CoordinationContext getCoordinationContext();
+
}
Modified: webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/CoordinatorImpl.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/CoordinatorImpl.java?rev=365398&r1=365397&r2=365398&view=diff
==============================================================================
--- webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/CoordinatorImpl.java (original)
+++ webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/CoordinatorImpl.java Mon Jan 2 11:13:33 2006
@@ -6,6 +6,7 @@
import java.rmi.RemoteException;
+import org.apache.axis.AxisFault;
import org.apache.axis.components.uuid.UUIDGen;
import org.apache.axis.components.uuid.UUIDGenFactory;
import org.apache.axis.message.addressing.EndpointReference;
@@ -22,7 +23,8 @@
private CoordinationContext ctx;
- public CoordinatorImpl(String coordinationType) throws MalformedURIException {
+ public CoordinatorImpl(String coordinationType)
+ throws MalformedURIException {
UUIDGen gen = UUIDGenFactory.getUUIDGen();
id = "uuid:" + gen.nextUUID();
CoordinationService cs = CoordinationService.getInstance();
@@ -39,20 +41,16 @@
}
public abstract EndpointReference register(String prot,
- EndpointReference pps) throws InvalidCoordinationProtocolException;
+ EndpointReference pps) throws AxisFault;
- public synchronized RegisterResponseType registerOperation(RegisterType params)
- throws RemoteException {
+ public synchronized RegisterResponseType registerOperation(
+ RegisterType params) throws RemoteException {
EndpointReference epr = null;
- try {
- epr = register(params.getProtocolIdentifier().toString(),
- new EndpointReference(params.getParticipantProtocolService()));
- } catch (InvalidCoordinationProtocolException e) {
- e.printStackTrace();
- throw new RemoteException(e.getMessage());
- }
+ epr = register(params.getProtocolIdentifier().toString(),
+ new EndpointReference(params.getParticipantProtocolService()));
RegisterResponseType r = new RegisterResponseType();
r.setCoordinatorProtocolService(epr);
return r;
}
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org