Author: dasarath
Date: Mon Jan 16 13:56:10 2006
New Revision: 369580
URL: http://svn.apache.org/viewcvs?rev=369580&view=rev
Log: (empty)
Modified:
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/at/ATCoordinatorImpl.java
Modified:
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/at/ATCoordinatorImpl.java
URL:
http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/at/ATCoordinatorImpl.java?rev=369580&r1=369579&r2=369580&view=diff
==============================================================================
---
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/at/ATCoordinatorImpl.java
(original)
+++
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/at/ATCoordinatorImpl.java
Mon Jan 16 13:56:10 2006
@@ -123,7 +123,7 @@
return;
case AT2PCStatus.COMMITTING:
- throwFault(participantRef, INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef, INVALID_STATE_SOAP_FAULT);
return;
case AT2PCStatus.ABORTING:
@@ -143,7 +143,7 @@
return;
case AT2PCStatus.COMMITTING:
- throwFault(participantRef, INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef, INVALID_STATE_SOAP_FAULT);
return;
case AT2PCStatus.ABORTING:
@@ -191,11 +191,11 @@
case AT2PCStatus.NONE:
if (volatile2PCParticipants.containsKey(participantRef))
- throwFault(participantRef,
INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef,
INVALID_STATE_SOAP_FAULT);
else {
epr = (EndpointReference)
durable2PCParticipants.get(participantRef);
if (epr == null)
- epr = getReplyToEpr();
+ epr =
org.apache.kandula.utils.AddressingHeaders.getReplyToOfCurrentMessage();
if (epr != null)
try {
getParticipantStub(participantRef, epr).rollbackOperation(
@@ -211,7 +211,7 @@
switch (status) {
case AT2PCStatus.ACTIVE:
try {
- throwFault(participantRef,
INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef,
INVALID_STATE_SOAP_FAULT);
} finally {
rollback();
}
@@ -235,11 +235,11 @@
case AT2PCStatus.ABORTING:
if (volatile2PCParticipants.remove(participantRef) !=
null)
- throwFault(participantRef,
INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef,
INVALID_STATE_SOAP_FAULT);
else {
epr = (EndpointReference)
durable2PCParticipants.remove(participantRef);
if (epr == null)
- epr = getReplyToEpr();
+ epr =
org.apache.kandula.utils.AddressingHeaders.getReplyToOfCurrentMessage();
if (epr != null) {
try {
getParticipantStub(participantRef, epr).rollbackOperation(
@@ -253,11 +253,11 @@
case AT2PCStatus.NONE:
if (volatile2PCParticipants.containsKey(participantRef))
- throwFault(participantRef,
INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef,
INVALID_STATE_SOAP_FAULT);
else {
epr = (EndpointReference)
durable2PCParticipants.get(participantRef);
if (epr == null)
- epr = getReplyToEpr();
+ epr =
org.apache.kandula.utils.AddressingHeaders.getReplyToOfCurrentMessage();
if (epr != null)
try {
getParticipantStub(participantRef, epr).rollbackOperation(
@@ -275,7 +275,7 @@
case AT2PCStatus.PREPARING_VOLATILE:
case AT2PCStatus.PREPARING_DURABLE:
try {
- throwFault(participantRef,
INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef,
INVALID_STATE_SOAP_FAULT);
} finally {
rollback();
}
@@ -286,7 +286,7 @@
return;
case AT2PCStatus.ABORTING:
- throwFault(participantRef, INVALID_STATE_SOAP_FAULT);
+ trigger(participantRef, INVALID_STATE_SOAP_FAULT);
return;
case AT2PCStatus.NONE:
@@ -445,7 +445,7 @@
}
private EndpointReference getEprToSendFault(String participantRef) {
- EndpointReference epr = getFaultToEpr();
+ EndpointReference epr =
org.apache.kandula.utils.AddressingHeaders.getFaultToOfCurrentMessage();
if (epr != null)
return epr;
return getEprToRespond(participantRef);
@@ -458,11 +458,11 @@
epr = (EndpointReference)
durable2PCParticipants.get(participantRef);
if (epr != null)
return epr;
- return getReplyToEpr();
+ return
org.apache.kandula.utils.AddressingHeaders.getReplyToOfCurrentMessage();
}
private String getParticipantRef() {
- AddressingHeaders headers = getAddressingHeaders();
+ AddressingHeaders headers =
org.apache.kandula.utils.AddressingHeaders.getAddressingHeadersOfCurrentMessage();
MessageElement e =
headers.getReferenceProperties().get(PARTICIPANT_REF);
return e.getValue();
}
@@ -488,9 +488,9 @@
}
}
- private void throwFault(String participantRef, AxisFault fault)
+ private void trigger(String participantRef, AxisFault fault)
throws AxisFault {
- throwFault(getEprToSendFault(participantRef), fault);
+ trigger(getEprToSendFault(participantRef), fault);
}
/*
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
