You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by gd...@apache.org on 2005/07/11 17:49:55 UTC
svn commit: r210150 [5/35] - in /webservices/axis/trunk/java: ./ etc/
modules/addressing/
modules/addressing/src/org/apache/axis2/handlers/addressing/
modules/addressing/test-resources/
modules/addressing/test/org/apache/axis2/handlers/addressing/ modu...
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/AxisFault.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/AxisFault.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/AxisFault.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/AxisFault.java Mon Jul 11 08:49:30 2005
@@ -29,16 +29,17 @@
* </ol>
*/
public class AxisFault extends java.rmi.RemoteException {
-
+
public AxisFault(Throwable arg1) {
- super(arg1.getMessage(), arg1);
- }
+ super(arg1.getMessage(), arg1);
+ }
+
/**
* @param arg0
*/
public AxisFault(String arg0) {
super(arg0);
- }
+ }
/**
* @param arg0
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DependencyManager.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DependencyManager.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DependencyManager.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DependencyManager.java Mon Jul 11 08:49:30 2005
@@ -24,23 +24,24 @@
public class DependencyManager {
private final static String MESSAGE_CONTEXT_INJECTION_METHOD = "init";
+
public static void configureBusinussLogicProvider(Object obj, MessageContext msgctx)
- throws AxisFault {
+ throws AxisFault {
try {
Class classToLoad = obj.getClass();
- Method[] methods = classToLoad.getMethods();
-
- for(int i = 0;i< methods.length ; i++){
- if(MESSAGE_CONTEXT_INJECTION_METHOD.equals(methods[i].getName()) && methods[i].getParameterTypes().length == 1 &&
- methods[i].getParameterTypes()[0] == MessageContext.class){
- methods[i].invoke(obj, new Object[] { msgctx });
+ Method[] methods = classToLoad.getMethods();
+
+ for (int i = 0; i < methods.length; i++) {
+ if (MESSAGE_CONTEXT_INJECTION_METHOD.equals(methods[i].getName()) && methods[i].getParameterTypes().length == 1 &&
+ methods[i].getParameterTypes()[0] == MessageContext.class) {
+ methods[i].invoke(obj, new Object[]{msgctx});
}
}
} catch (SecurityException e) {
throw new AxisFault(e);
} catch (IllegalArgumentException e) {
throw new AxisFault(e);
- }catch (IllegalAccessException e) {
+ } catch (IllegalAccessException e) {
throw new AxisFault(e);
} catch (InvocationTargetException e) {
throw new AxisFault(e);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DispatchPostConditionsEvaluator.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DispatchPostConditionsEvaluator.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DispatchPostConditionsEvaluator.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/DispatchPostConditionsEvaluator.java Mon Jul 11 08:49:30 2005
@@ -31,7 +31,7 @@
* Field NAME
*/
public static final QName NAME =
- new QName("http://axis.ws.apache.org", "DispatchPostConditionsEvaluator");
+ new QName("http://axis.ws.apache.org", "DispatchPostConditionsEvaluator");
/**
* Constructor Dispatcher
@@ -51,11 +51,11 @@
public final void invoke(MessageContext msgctx) throws AxisFault {
EndpointReference toEPR = msgctx.getTo();
if (msgctx.getServiceContext() == null) {
- throw new AxisFault("Service Not found EPR is " + ((toEPR!= null)?toEPR.getAddress():""));
+ throw new AxisFault("Service Not found EPR is " + ((toEPR != null) ? toEPR.getAddress() : ""));
}
if (msgctx.getServiceContext() != null && msgctx.getOperationContext() == null) {
- throw new AxisFault("Operation Not found EPR is " + ((toEPR!= null)?toEPR.getAddress():"") + " and WSA Action = "+ msgctx.getWSAAction());
+ throw new AxisFault("Operation Not found EPR is " + ((toEPR != null) ? toEPR.getAddress() : "") + " and WSA Action = " + msgctx.getWSAAction());
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/MessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/MessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/MessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/MessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -20,6 +20,6 @@
/**
* Interface Receiver
*/
-public interface MessageReceiver{
- public void recieve(MessageContext messgeCtx)throws AxisFault;
+public interface MessageReceiver {
+ public void recieve(MessageContext messgeCtx) throws AxisFault;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/Phase.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/Phase.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/Phase.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/Phase.java Mon Jul 11 08:49:30 2005
@@ -109,8 +109,7 @@
* @param index
*/
public void addHandler(Handler handler, int index) {
- log.info(
- "Handler " + handler.getName() + "Added to place " + 1 + " At the Phase " + phaseName);
+ log.info("Handler " + handler.getName() + "Added to place " + 1 + " At the Phase " + phaseName);
handlers.add(index, handler);
}
@@ -137,11 +136,10 @@
if (msgctx.isPaused()) {
return;
} else {
- log.info(
- "Invoke the Phase first handler "
- + phaseFirst.getName()
- + "with in the Phase "
- + phaseName);
+ log.info("Invoke the Phase first handler "
+ + phaseFirst.getName()
+ + "with in the Phase "
+ + phaseName);
phaseFirst.invoke(msgctx);
}
}
@@ -153,11 +151,10 @@
} else {
Handler handler = (Handler) handlers.get(indexOfHandlerToExecute);
if (handler != null) {
- log.info(
- "Invoke the Handler "
- + handler.getName()
- + "with in the Phase "
- + phaseName);
+ log.info("Invoke the Handler "
+ + handler.getName()
+ + "with in the Phase "
+ + phaseName);
handler.invoke(msgctx);
//This line should be after the invoke as if the invocation failed this handlers is takn care of and
//no need to revoke agien
@@ -170,11 +167,10 @@
if (msgctx.isPaused()) {
return;
} else {
- log.info(
- "Invoke the Phase first handler "
- + phaseLast.getName()
- + "with in the Phase "
- + phaseName);
+ log.info("Invoke the Phase first handler "
+ + phaseLast.getName()
+ + "with in the Phase "
+ + phaseName);
phaseLast.invoke(msgctx);
}
}
@@ -203,15 +199,14 @@
*/
private int getBeforeAfter(Handler handler) throws PhaseException {
if ((!handler.getHandlerDesc().getRules().getBefore().equals(""))
- && (!handler.getHandlerDesc().getRules().getAfter().equals(""))) {
+ && (!handler.getHandlerDesc().getRules().getAfter().equals(""))) {
if (handler
- .getHandlerDesc()
- .getRules()
- .getBefore()
- .equals(handler.getHandlerDesc().getRules().getAfter())) {
- throw new PhaseException(
- "Both before and after cannot be the same for this handler"
- + handler.getName());
+ .getHandlerDesc()
+ .getRules()
+ .getBefore()
+ .equals(handler.getHandlerDesc().getRules().getAfter())) {
+ throw new PhaseException("Both before and after cannot be the same for this handler"
+ + handler.getName());
}
return BOTH_BEFORE_AFTER;
} else if (!handler.getHandlerDesc().getRules().getBefore().equals("")) {
@@ -231,14 +226,12 @@
*/
public void setPhaseFirst(Handler phaseFirst) throws PhaseException {
if (phasefirstset) {
- throw new PhaseException(
- "PhaseFirst alredy has been set, cannot have two phaseFirst Handler for same phase "
- + this.getPhaseName());
+ throw new PhaseException("PhaseFirst alredy has been set, cannot have two phaseFirst Handler for same phase "
+ + this.getPhaseName());
} else {
if (getBeforeAfter(phaseFirst) != ANYWHERE) {
- throw new PhaseException(
- "Handler with PhaseFirst can not have any before or after proprty error in "
- + phaseFirst.getName());
+ throw new PhaseException("Handler with PhaseFirst can not have any before or after proprty error in "
+ + phaseFirst.getName());
} else {
this.phaseFirst = phaseFirst;
}
@@ -254,14 +247,12 @@
*/
public void setPhaseLast(Handler phaseLast) throws PhaseException {
if (phaselastset) {
- throw new PhaseException(
- "PhaseLast already has been set, cannot have two PhaseLast Handler for same phase "
- + this.getPhaseName());
+ throw new PhaseException("PhaseLast already has been set, cannot have two PhaseLast Handler for same phase "
+ + this.getPhaseName());
} else {
if (getBeforeAfter(phaseLast) != ANYWHERE) {
- throw new PhaseException(
- "Handler with PhaseLast property can not have any before or after property error in "
- + phaseLast.getName());
+ throw new PhaseException("Handler with PhaseLast property can not have any before or after property error in "
+ + phaseLast.getName());
} else {
this.phaseLast = phaseLast;
}
@@ -277,18 +268,16 @@
*/
public void addHandler(HandlerDescription handler) throws PhaseException {
if (isonehanlder) {
- throw new PhaseException(
- this.getPhaseName()
- + "can only have one handler, since there is a "
- + "handler with both phaseFirst and PhaseLast true ");
+ throw new PhaseException(this.getPhaseName()
+ + "can only have one handler, since there is a "
+ + "handler with both phaseFirst and PhaseLast true ");
} else {
if (handler.getRules().isPhaseFirst() && handler.getRules().isPhaseLast()) {
if (handlers.size() > 0) {
- throw new PhaseException(
- this.getPhaseName()
- + " can not have more than one handler "
- + handler.getName()
- + " is invalid or incorrect phase rules");
+ throw new PhaseException(this.getPhaseName()
+ + " can not have more than one handler "
+ + handler.getName()
+ + " is invalid or incorrect phase rules");
} else {
handlers.add(handler.getHandler());
isonehanlder = true;
@@ -319,11 +308,10 @@
if (phaseFirst != null) {
String phasFirstname = phaseFirst.getHandlerDesc().getName().getLocalPart();
if (handler.getHandlerDesc().getRules().getBefore().equals(phasFirstname)) {
- throw new PhaseException(
- "Trying to insert a Handler "
- + handler.getName()
- + " before phaseFirst "
- + phasFirstname);
+ throw new PhaseException("Trying to insert a Handler "
+ + handler.getName()
+ + " before phaseFirst "
+ + phasFirstname);
}
}
}
@@ -338,11 +326,10 @@
if (phaseLast != null) {
String phaseLastName = phaseLast.getHandlerDesc().getName().getLocalPart();
if (handler.getName().equals(phaseLastName)) {
- throw new PhaseException(
- "Try to insert a Handler "
- + handler.getName()
- + " after phaseLast "
- + phaseLastName);
+ throw new PhaseException("Try to insert a Handler "
+ + handler.getName()
+ + " after phaseLast "
+ + phaseLastName);
}
}
}
@@ -425,11 +412,11 @@
*/
if ((phaseFirst != null) && (phaseLast != null)) {
if ((phaseFirst
- .getHandlerDesc()
- .getName()
- .getLocalPart()
- .equals(handler.getHandlerDesc().getRules().getAfter()))
- && (phaseLast
+ .getHandlerDesc()
+ .getName()
+ .getLocalPart()
+ .equals(handler.getHandlerDesc().getRules().getAfter()))
+ && (phaseLast
.getHandlerDesc()
.getName()
.getLocalPart()
@@ -440,7 +427,7 @@
}
if (phaseFirst != null
- && (phaseFirst
+ && (phaseFirst
.getHandlerDesc()
.getName()
.getLocalPart()
@@ -448,7 +435,7 @@
after = 0;
}
if (phaseLast != null
- && (phaseLast
+ && (phaseLast
.getHandlerDesc()
.getName()
.getLocalPart()
@@ -459,22 +446,20 @@
for (int i = 0; i < handlers.size(); i++) {
Handler temphandler = (Handler) handlers.get(i);
if (handler
- .getHandlerDesc()
- .getRules()
- .getAfter()
- .equals(temphandler.getHandlerDesc().getName().getLocalPart())) {
+ .getHandlerDesc()
+ .getRules()
+ .getAfter()
+ .equals(temphandler.getHandlerDesc().getName().getLocalPart())) {
after = i;
} else if (
- handler.getHandlerDesc().getRules().getBefore().equals(
- temphandler.getHandlerDesc().getName().getLocalPart())) {
+ handler.getHandlerDesc().getRules().getBefore().equals(temphandler.getHandlerDesc().getName().getLocalPart())) {
before = i;
}
if ((after >= 0) && (before >= 0)) {
// no point of continue since both the before and after index has found
if (after > before) {
//TODO fix me Deepal , (have to check this)
- throw new PhaseException(
- "incorrect handler order for " + handler.getHandlerDesc().getName());
+ throw new PhaseException("incorrect handler order for " + handler.getHandlerDesc().getName());
} else {
if (after + 1 <= handlers.size()) {
handlers.add(after + 1, handler);
@@ -495,22 +480,22 @@
validateafter(han);
validatebefore(han);
switch (type) {
- case BOTH_BEFORE_AFTER :
+ case BOTH_BEFORE_AFTER:
{
insertBeforeandAfter(han);
break;
}
- case BEFORE :
+ case BEFORE:
{
insertBefore(han);
break;
}
- case AFTER :
+ case AFTER:
{
insertAfter(han);
break;
}
- case ANYWHERE :
+ case ANYWHERE:
{
handlers.add(han);
break;
@@ -520,6 +505,7 @@
/**
* To get the all the handlers in the phase
+ *
* @return
*/
public ArrayList getHandlers() {
@@ -536,17 +522,18 @@
}
return phaseHandlers;
}
+
public void invokeStartFromHandler(QName name, MessageContext msgctx) throws AxisFault {
msgctx.setPausedPhaseName(this.getPhaseName());
boolean foudMatch = false;
ArrayList phaseHandlers = getHandlers();
for (int i = 0; i < phaseHandlers.size(); i++) {
Handler handler = (Handler) handlers.get(i);
- if(handler != null && handler.getName().equals(name)){
+ if (handler != null && handler.getName().equals(name)) {
foudMatch = true;
}
-
- if(handler != null && foudMatch){
+
+ if (handler != null && foudMatch) {
handler.invoke(msgctx);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/RequestURIBasedDispatcher.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/RequestURIBasedDispatcher.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/RequestURIBasedDispatcher.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/RequestURIBasedDispatcher.java Mon Jul 11 08:49:30 2005
@@ -32,7 +32,7 @@
* Field NAME
*/
public static final QName NAME =
- new QName("http://axis.ws.apache.org", "RequestURIBasedDispatcher");
+ new QName("http://axis.ws.apache.org", "RequestURIBasedDispatcher");
QName serviceName = null;
QName operatoinName = null;
@@ -43,10 +43,9 @@
init(new HandlerDescription(NAME));
}
- public OperationDescription findOperation(
- ServiceDescription service,
- MessageContext messageContext)
- throws AxisFault {
+ public OperationDescription findOperation(ServiceDescription service,
+ MessageContext messageContext)
+ throws AxisFault {
if (operatoinName != null) {
OperationDescription axisOp = service.getOperation(operatoinName);
return axisOp;
@@ -69,7 +68,7 @@
if (values[0] != null) {
serviceName = new QName(values[0]);
AxisConfiguration registry =
- messageContext.getSystemContext().getAxisConfiguration();
+ messageContext.getSystemContext().getAxisConfiguration();
return registry.getService(serviceName);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPActionBasedDispatcher.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPActionBasedDispatcher.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPActionBasedDispatcher.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPActionBasedDispatcher.java Mon Jul 11 08:49:30 2005
@@ -30,21 +30,20 @@
* Field NAME
*/
public static final QName NAME =
- new QName("http://axis.ws.apache.org", "SOAPActionBasedDispatcher");
+ new QName("http://axis.ws.apache.org", "SOAPActionBasedDispatcher");
public SOAPActionBasedDispatcher() {
init(new HandlerDescription(NAME));
}
- public OperationDescription findOperation(
- ServiceDescription service,
- MessageContext messageContext)
- throws AxisFault {
+ public OperationDescription findOperation(ServiceDescription service,
+ MessageContext messageContext)
+ throws AxisFault {
String action = (String) messageContext.getSoapAction();
if (action != null) {
OperationDescription op = service.getOperationBySOAPAction(action);
- if(op == null){
+ if (op == null) {
op = service.getOperation(new QName(action));
}
return op;
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPMessageBodyBasedDispatcher.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPMessageBodyBasedDispatcher.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPMessageBodyBasedDispatcher.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/engine/SOAPMessageBodyBasedDispatcher.java Mon Jul 11 08:49:30 2005
@@ -15,7 +15,6 @@
*/
package org.apache.axis2.engine;
-import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.description.HandlerDescription;
import org.apache.axis2.description.OperationDescription;
@@ -34,7 +33,7 @@
* Field NAME
*/
public static final QName NAME =
- new QName("http://axis.ws.apache.org", "SOAPMessageBodyBasedDispatcher");
+ new QName("http://axis.ws.apache.org", "SOAPMessageBodyBasedDispatcher");
QName serviceName = null;
QName operatoinName = null;
@@ -45,10 +44,9 @@
init(new HandlerDescription(NAME));
}
- public OperationDescription findOperation(
- ServiceDescription service,
- MessageContext messageContext)
- throws AxisFault {
+ public OperationDescription findOperation(ServiceDescription service,
+ MessageContext messageContext)
+ throws AxisFault {
OMElement bodyFirstChild = messageContext.getEnvelope().getBody().getFirstElement();
operatoinName = new QName(bodyFirstChild.getLocalName());
@@ -73,7 +71,7 @@
if (values[0] != null) {
serviceName = new QName(values[0]);
AxisConfiguration registry =
- messageContext.getSystemContext().getAxisConfiguration();
+ messageContext.getSystemContext().getAxisConfiguration();
return registry.getService(serviceName);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/handlers/AbstractHandler.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/handlers/AbstractHandler.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/handlers/AbstractHandler.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/handlers/AbstractHandler.java Mon Jul 11 08:49:30 2005
@@ -99,12 +99,13 @@
public HandlerDescription getHandlerDesc() {
return handlerDesc;
}
+
/* (non-Javadoc)
* @see java.lang.Object#toString()
*/
public String toString() {
QName name = this.getName();
- return (name!=null)?name.toString():null;
+ return (name != null) ? name.toString() : null;
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/modules/Module.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/modules/Module.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/modules/Module.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/modules/Module.java Mon Jul 11 08:49:30 2005
@@ -26,7 +26,7 @@
* be in the "available" state. If some service indicates a dependency on this
* module then the module is initialized (once for the life of the system) and
* the state changes to "initialized".
- *
+ * <p/>
* <p/>Any module which is in the "initialized" state can be engaged as needed
* by the engine to respond to a message. Currently module engagement is done
* via deployment (using module.xml). In the future we may engage modules
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseHolder.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseHolder.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseHolder.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseHolder.java Mon Jul 11 08:49:30 2005
@@ -65,9 +65,9 @@
getPhase(phaseName).addHandler(handler);
} else {
throw new PhaseException("Invalid Phase ," + phaseName
- + "for the handler "
- + handler.getName()
- + " dose not exit in axis2.xml or refering to phase in diffrent flow");
+ + "for the handler "
+ + handler.getName()
+ + " dose not exit in axis2.xml or refering to phase in diffrent flow");
}
}
@@ -90,6 +90,7 @@
/**
* This method is to build the transport phase , here load the corresponding handlers and added them
* in to correct phase
+ *
* @param phase
* @param handlers
* @throws PhaseException
@@ -101,7 +102,7 @@
for (int i = 0; i < handlers.size(); i++) {
HandlerDescription description = (HandlerDescription) handlers.get(i);
handlerClass = Class.forName(description.getClassName(), true,
- Thread.currentThread().getContextClassLoader());
+ Thread.currentThread().getContextClassLoader());
handler =
(Handler) handlerClass.newInstance();
handler.init(description);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseResolver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseResolver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseResolver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/phaseresolver/PhaseResolver.java Mon Jul 11 08:49:30 2005
@@ -35,7 +35,7 @@
/**
* Field axisConfig
*/
- private AxisConfiguration axisConfig;
+ private AxisConfiguration axisConfig;
/**
* Field axisService
@@ -276,7 +276,7 @@
handlers.add(metadata);
}
new PhaseHolder().buildTransportHandlerChain(phase, handlers);
- }else {
+ } else {
continue;
}
}
@@ -316,12 +316,12 @@
handlers.add(metadata);
}
new PhaseHolder().buildTransportHandlerChain(phase, handlers);
- }else {
+ } else {
continue;
}
}
}
-
+
public void engageModuleGlobally(ModuleDescription module) throws AxisFault {
enageToGlobalChain(module);
@@ -348,10 +348,10 @@
boolean engaged = false;
for (Iterator iterator = opCol.iterator(); iterator.hasNext();) {
OperationDescription opDesc = (OperationDescription) iterator.next();
- Collection modules = opDesc.getModules();
+ Collection modules = opDesc.getModules();
for (Iterator iterator1 = modules.iterator(); iterator1.hasNext();) {
ModuleDescription description = (ModuleDescription) iterator1.next();
- if(description.getName().equals(module.getName())){
+ if (description.getName().equals(module.getName())) {
engaged = true;
break;
}
@@ -500,16 +500,16 @@
boolean engaged = false;
for (Iterator iterator = opCol.iterator(); iterator.hasNext();) {
OperationDescription opDesc = (OperationDescription) iterator.next();
- Collection modules = opDesc.getModules();
+ Collection modules = opDesc.getModules();
for (Iterator iterator1 = modules.iterator(); iterator1.hasNext();) {
ModuleDescription description = (ModuleDescription) iterator1.next();
- if(description.getName().equals(module.getName())){
+ if (description.getName().equals(module.getName())) {
engaged = true;
break;
}
}
if (!engaged) {
- engageModuleToOperation(opDesc,module);
+ engageModuleToOperation(opDesc, module);
opDesc.addToEngageModuleList(module);
}
}
@@ -573,7 +573,7 @@
phaseHolder.addHandler(metadata);
} else {
throw new PhaseException("Service specific module can not refer system pre defined phases : "
- + metadata.getRules().getPhaseName());
+ + metadata.getRules().getPhaseName());
}
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -24,9 +24,10 @@
* This is takes care of the IN-OUT sync MEP in the server side
*/
public abstract class AbstractInMessageReceiver
- extends AbstractMessageReceiver {
- protected Log log = LogFactory.getLog(getClass());
- public abstract void invokeBusinessLogic(MessageContext inMessage)throws AxisFault;
+ extends AbstractMessageReceiver {
+ protected Log log = LogFactory.getLog(getClass());
+
+ public abstract void invokeBusinessLogic(MessageContext inMessage) throws AxisFault;
public final void recieve(final MessageContext messgeCtx) throws AxisFault {
invokeBusinessLogic(messgeCtx);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -25,27 +25,29 @@
* This is takes care of the IN-OUT sync MEP in the server side
*/
public abstract class AbstractInOutAsyncMessageReceiver
- extends AbstractMessageReceiver {
- protected Log log = LogFactory.getLog(getClass());
- public abstract void invokeBusinessLogic(MessageContext inMessage,ServerCallback callback)
- throws AxisFault;
+ extends AbstractMessageReceiver {
+ protected Log log = LogFactory.getLog(getClass());
+
+ public abstract void invokeBusinessLogic(MessageContext inMessage, ServerCallback callback)
+ throws AxisFault;
public final void recieve(final MessageContext messgeCtx) throws AxisFault {
final ServerCallback callback = new ServerCallback() {
- public void handleResult(MessageContext result)throws AxisFault {
+ public void handleResult(MessageContext result) throws AxisFault {
AxisEngine engine =
- new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
+ new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
engine.send(messgeCtx);
}
- public void handleFault(AxisFault fault)throws AxisFault{
+
+ public void handleFault(AxisFault fault) throws AxisFault {
AxisEngine engine = new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
- engine.handleFault(messgeCtx,fault);
+ engine.handleFault(messgeCtx, fault);
}
};
Runnable theadedTask = new Runnable() {
public void run() {
try {
- invokeBusinessLogic(messgeCtx,callback);
+ invokeBusinessLogic(messgeCtx, callback);
} catch (AxisFault e) {
log.error(e);
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutSyncMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutSyncMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutSyncMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractInOutSyncMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -28,43 +28,39 @@
* protected abstract methods are only for the sake of breaking down the logic
*/
public abstract class AbstractInOutSyncMessageReceiver extends AbstractMessageReceiver {
- public abstract void invokeBusinessLogic(
- MessageContext inMessage,
- MessageContext outMessage)
- throws AxisFault;
+ public abstract void invokeBusinessLogic(MessageContext inMessage,
+ MessageContext outMessage)
+ throws AxisFault;
public final void recieve(MessageContext messgeCtx) throws AxisFault {
MessageContext newmsgCtx =
- new MessageContext(messgeCtx.getSystemContext(),
- messgeCtx.getSessionContext(),
- messgeCtx.getTransportIn(),
- messgeCtx.getTransportOut());
+ new MessageContext(messgeCtx.getSystemContext(),
+ messgeCtx.getSessionContext(),
+ messgeCtx.getTransportIn(),
+ messgeCtx.getTransportOut());
newmsgCtx.setMessageInformationHeaders(new MessageInformationHeadersCollection());
MessageInformationHeadersCollection oldMessageInfoHeaders =
- messgeCtx.getMessageInformationHeaders();
+ messgeCtx.getMessageInformationHeaders();
MessageInformationHeadersCollection messageInformationHeaders =
- new MessageInformationHeadersCollection();
+ new MessageInformationHeadersCollection();
messageInformationHeaders.setTo(oldMessageInfoHeaders.getReplyTo());
messageInformationHeaders.setFaultTo(oldMessageInfoHeaders.getFaultTo());
messageInformationHeaders.setFrom(oldMessageInfoHeaders.getTo());
- messageInformationHeaders.setRelatesTo(
- new RelatesTo(
- oldMessageInfoHeaders.getMessageId(),
- AddressingConstants.Submission.WSA_RELATES_TO_RELATIONSHIP_TYPE_DEFAULT_VALUE));
- newmsgCtx.setMessageInformationHeaders(messageInformationHeaders);
+ messageInformationHeaders.setRelatesTo(new RelatesTo(oldMessageInfoHeaders.getMessageId(),
+ AddressingConstants.Submission.WSA_RELATES_TO_RELATIONSHIP_TYPE_DEFAULT_VALUE));
+ newmsgCtx.setMessageInformationHeaders(messageInformationHeaders);
newmsgCtx.setOperationContext(messgeCtx.getOperationContext());
newmsgCtx.setServiceContext(messgeCtx.getServiceContext());
- newmsgCtx.setProperty(MessageContext.TRANSPORT_OUT,messgeCtx.getProperty(MessageContext.TRANSPORT_OUT));
- newmsgCtx.setProperty(HTTPConstants.HTTPOutTransportInfo,messgeCtx.getProperty(HTTPConstants.HTTPOutTransportInfo));
+ newmsgCtx.setProperty(MessageContext.TRANSPORT_OUT, messgeCtx.getProperty(MessageContext.TRANSPORT_OUT));
+ newmsgCtx.setProperty(HTTPConstants.HTTPOutTransportInfo, messgeCtx.getProperty(HTTPConstants.HTTPOutTransportInfo));
newmsgCtx.setDoingREST(messgeCtx.isDoingREST());
newmsgCtx.setDoingMTOM(messgeCtx.isDoingMTOM());
-
- invokeBusinessLogic(messgeCtx,newmsgCtx);
+
+ invokeBusinessLogic(messgeCtx, newmsgCtx);
AxisEngine engine =
- new AxisEngine(
- messgeCtx.getOperationContext().getServiceContext().getEngineContext());
+ new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
engine.send(newmsgCtx);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -22,7 +22,6 @@
import org.apache.axis2.context.SessionContext;
import org.apache.axis2.description.Parameter;
import org.apache.axis2.description.ServiceDescription;
-import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.engine.AxisFault;
import org.apache.axis2.engine.MessageReceiver;
import org.apache.axis2.om.OMAbstractFactory;
@@ -54,17 +53,17 @@
fac = OMAbstractFactory.getSOAP12Factory();
} else if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(nsURI)) {
fac = OMAbstractFactory.getSOAP11Factory();
- }else {
+ } else {
throw new AxisFault("Unknown SOAP Version. Current Axis handles only SOAP 1.1 and SOAP 1.2 messages");
}
ServiceDescription service =
- msgContext.getOperationContext().getServiceContext().getServiceConfig();
+ msgContext.getOperationContext().getServiceContext().getServiceConfig();
ClassLoader classLoader = service.getClassLoader();
Parameter implInfoParam = service.getParameter(SERVICE_CLASS);
if (implInfoParam != null) {
Class implClass =
- Class.forName((String) implInfoParam.getValue(), true, classLoader);
+ Class.forName((String) implInfoParam.getValue(), true, classLoader);
return implClass.newInstance();
} else {
throw new AxisFault("SERVICE_CLASS parameter is not specified");
@@ -76,21 +75,21 @@
}
/**
- * Method getTheImplementationObject
- *
- * @param msgContext
- * @return
- * @throws AxisFault
- */
+ * Method getTheImplementationObject
+ *
+ * @param msgContext
+ * @return
+ * @throws AxisFault
+ */
protected Object getTheImplementationObject(MessageContext msgContext) throws AxisFault {
ServiceDescription service =
- msgContext.getOperationContext().getServiceContext().getServiceConfig();
+ msgContext.getOperationContext().getServiceContext().getServiceConfig();
Parameter scopeParam = service.getParameter(SCOPE);
QName serviceName = service.getName();
- if (scopeParam != null && Constants.SESSION_SCOPE.equals(scopeParam.getValue())) {
+ if (scopeParam != null && Constants.SESSION_SCOPE.equals(scopeParam.getValue())) {
SessionContext sessionContext = msgContext.getSessionContext();
- synchronized(sessionContext){
+ synchronized (sessionContext) {
Object obj = sessionContext.getProperty(serviceName.getLocalPart());
if (obj == null) {
obj = makeNewServiceObject(msgContext);
@@ -98,9 +97,9 @@
}
return obj;
}
- } else if (scopeParam != null && Constants.APPLICATION_SCOPE.equals(scopeParam.getValue())) {
+ } else if (scopeParam != null && Constants.APPLICATION_SCOPE.equals(scopeParam.getValue())) {
ConfigurationContext globalContext = msgContext.getSystemContext();
- synchronized(globalContext){
+ synchronized (globalContext) {
Object obj = globalContext.getProperty(serviceName.getLocalPart());
if (obj == null) {
obj = makeNewServiceObject(msgContext);
@@ -113,7 +112,7 @@
}
}
- public SOAPFactory getSOAPFactory(){
+ public SOAPFactory getSOAPFactory() {
return fac;
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -25,17 +25,18 @@
* This is takes care of the IN-OUT sync MEP in the server side
*/
public abstract class AbstractRobustInMessageReceiver
- extends AbstractMessageReceiver {
- protected Log log = LogFactory.getLog(getClass());
- public abstract void invokeBusinessLogic(MessageContext inMessage)throws AxisFault;
+ extends AbstractMessageReceiver {
+ protected Log log = LogFactory.getLog(getClass());
+
+ public abstract void invokeBusinessLogic(MessageContext inMessage) throws AxisFault;
public final void recieve(final MessageContext messgeCtx) throws AxisFault {
try {
- invokeBusinessLogic(messgeCtx);
- } catch (AxisFault e) {
- AxisEngine engine = new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
- engine.handleFault(messgeCtx,e);
- }
+ invokeBusinessLogic(messgeCtx);
+ } catch (AxisFault e) {
+ AxisEngine engine = new AxisEngine(messgeCtx.getOperationContext().getServiceContext().getEngineContext());
+ engine.handleFault(messgeCtx, e);
+ }
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -36,8 +36,8 @@
* This is a Simple java Provider.
*/
public class RawXMLINOnlyMessageReceiver
- extends AbstractInMessageReceiver
- implements MessageReceiver {
+ extends AbstractInMessageReceiver
+ implements MessageReceiver {
/**
* Field log
*/
@@ -66,7 +66,7 @@
}
public void invokeBusinessLogic(MessageContext msgContext)
- throws AxisFault {
+ throws AxisFault {
try {
// get the implementation class for the Web Service
@@ -74,7 +74,7 @@
// find the WebService method
Class ImplClass = obj.getClass();
- DependencyManager.configureBusinussLogicProvider(obj,msgContext);
+ DependencyManager.configureBusinussLogicProvider(obj, msgContext);
OperationDescription op = msgContext.getOperationContext().getAxisOperation();
if (op == null) {
@@ -90,8 +90,8 @@
}
Class[] parameters = method.getParameterTypes();
if ((parameters != null)
- && (parameters.length == 1)
- && OMElement.class.getName().equals(parameters[0].getName())) {
+ && (parameters.length == 1)
+ && OMElement.class.getName().equals(parameters[0].getName())) {
OMElement methodElement = msgContext.getEnvelope().getBody().getFirstElement();
OMElement parmeter = null;
@@ -101,7 +101,7 @@
if (WSDLService.STYLE_DOC.equals(style)) {
parmeter = methodElement;
- Object[] parms = new Object[] { parmeter };
+ Object[] parms = new Object[]{parmeter};
// invoke the WebService
OMElement result = (OMElement) method.invoke(obj, parms);
@@ -110,7 +110,7 @@
} else if (WSDLService.STYLE_RPC.equals(style)) {
parmeter = methodElement.getFirstElement();
- Object[] parms = new Object[] { parmeter };
+ Object[] parms = new Object[]{parmeter};
// invoke the WebService
OMElement result = (OMElement) method.invoke(obj, parms);
@@ -129,9 +129,8 @@
throw new AxisFault("Unknown style ");
}
} else {
- throw new AxisFault(
- "Raw Xml provider supports only the methods bearing the signature public OMElement "
- + "<method-name>(OMElement) where the method name is anything");
+ throw new AxisFault("Raw Xml provider supports only the methods bearing the signature public OMElement "
+ + "<method-name>(OMElement) where the method name is anything");
}
} catch (Exception e) {
throw AxisFault.makeFault(e);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java Mon Jul 11 08:49:30 2005
@@ -34,8 +34,8 @@
* This is a Simple java Provider.
*/
public class RawXMLINOutMessageReceiver
- extends AbstractInOutSyncMessageReceiver
- implements MessageReceiver {
+ extends AbstractInOutSyncMessageReceiver
+ implements MessageReceiver {
/**
* Field log
*/
@@ -59,7 +59,7 @@
}
public void invokeBusinessLogic(MessageContext msgContext, MessageContext newmsgContext)
- throws AxisFault {
+ throws AxisFault {
try {
// get the implementation class for the Web Service
@@ -88,11 +88,11 @@
} else if (WSDLService.STYLE_RPC.equals(style)) {
OMElement operationElement = msgContext.getEnvelope().getBody().getFirstElement();
if (operationElement != null) {
- if (method.getName().equals(operationElement.getLocalName())
- || operationElement.getLocalName() != null && operationElement.getLocalName().startsWith(method.getName()) ) {
+ if (method.getName().equals(operationElement.getLocalName())
+ || operationElement.getLocalName() != null && operationElement.getLocalName().startsWith(method.getName())) {
omElement = operationElement.getFirstElement();
} else {
- throw new AxisFault("Operation Name does not match the immediate child name, expected "+ method.getName() + " but get " + operationElement.getLocalName());
+ throw new AxisFault("Operation Name does not match the immediate child name, expected " + method.getName() + " but get " + operationElement.getLocalName());
}
} else {
throw new AxisFault("rpc style expect the immediate child of the SOAP body ");
@@ -100,33 +100,31 @@
} else {
throw new AxisFault("Unknown style ");
}
- args = new Object[] { omElement };
+ args = new Object[]{omElement};
} else {
- throw new AxisFault(
- "Raw Xml provider supports only the methods bearing the signature public OMElement "
- + "<method-name>(OMElement) where the method name is anything");
+ throw new AxisFault("Raw Xml provider supports only the methods bearing the signature public OMElement "
+ + "<method-name>(OMElement) where the method name is anything");
}
OMElement result = (OMElement) method.invoke(obj, args);
-
+
OMElement bodyContent = null;
if (WSDLService.STYLE_RPC.equals(style)) {
OMNamespace ns = getSOAPFactory().createOMNamespace("http://soapenc/", "res");
bodyContent =
- getSOAPFactory().createOMElement(method.getName() + "Response", ns);
+ getSOAPFactory().createOMElement(method.getName() + "Response", ns);
bodyContent.addChild(result);
- }else{
+ } else {
bodyContent = result;
}
SOAPEnvelope envelope = getSOAPFactory().getDefaultEnvelope();
- if(bodyContent!= null){
+ if (bodyContent != null) {
envelope.getBody().addChild(bodyContent);
}
newmsgContext.setEnvelope(envelope);
} else {
- throw new AxisFault(
- "Implementation class does not define a method called" + opDesc.getName());
+ throw new AxisFault("Implementation class does not define a method called" + opDesc.getName());
}
} catch (Exception e) {
throw AxisFault.makeFault(e);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java Mon Jul 11 08:49:30 2005
@@ -20,6 +20,7 @@
public interface ServerCallback {
- public void handleResult(MessageContext result)throws AxisFault;
- public void handleFault(AxisFault fault)throws AxisFault;
+ public void handleResult(MessageContext result) throws AxisFault;
+
+ public void handleFault(AxisFault fault) throws AxisFault;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java Mon Jul 11 08:49:30 2005
@@ -17,10 +17,12 @@
*
*
*/
+
public interface AxisStorage {
/**
* puts a value to the storage
+ *
* @param value
* @return the key as an Object
*/
@@ -28,6 +30,7 @@
/**
* get a value from the storage. The value is not removed
+ *
* @param key
* @return the value as an Object
*/
@@ -35,6 +38,7 @@
/**
* Removes an object from the storage given the key.
+ *
* @param key
* @return the value being removed as an object
*/
@@ -42,6 +46,7 @@
/**
* Cleans the whole storage.
+ *
* @return a boolean saying whether the clean was successful or not
*/
boolean clean();
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java Mon Jul 11 08:49:30 2005
@@ -19,13 +19,14 @@
*
*
*/
-public abstract class AbstractStorage implements AxisStorage{
- private static int key=0;
+public abstract class AbstractStorage implements AxisStorage {
- protected String getUniqueKey(){
- if (key==Integer.MAX_VALUE){
- key=0;
+ private static int key = 0;
+
+ protected String getUniqueKey() {
+ if (key == Integer.MAX_VALUE) {
+ key = 0;
}
return Integer.toString(key++);
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java Mon Jul 11 08:49:30 2005
@@ -23,7 +23,8 @@
*
*
*/
-public class AxisFileStorage extends AbstractStorage{
+
+public class AxisFileStorage extends AbstractStorage {
private File file;
private FileOutputStream fos;
@@ -55,7 +56,7 @@
try {
String key = getUniqueKey();
- map.put(key,value);
+ map.put(key, value);
updateFileState();
@@ -91,7 +92,7 @@
}
public boolean clean() {
- try {
+ try {
map.clear();
updateFileState();
return true;
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java Mon Jul 11 08:49:30 2005
@@ -1,4 +1,5 @@
package org.apache.axis2.storage.impl;
+
import java.util.HashMap;
/*
@@ -18,7 +19,8 @@
*
*
*/
-public class AxisMemoryStorage extends AbstractStorage{
+
+public class AxisMemoryStorage extends AbstractStorage {
private HashMap objectMap;
@@ -29,7 +31,7 @@
public Object put(Object value) {
String key = getUniqueKey();
- objectMap.put(key,value);
+ objectMap.put(key, value);
return key;
}
@@ -47,12 +49,11 @@
try {
objectMap.clear();
returnValue = true;
- }catch(Exception e){
+ } catch (Exception e) {
returnValue = false;
}
return returnValue;
}
-
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/AbstractTransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/AbstractTransportSender.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/AbstractTransportSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/AbstractTransportSender.java Mon Jul 11 08:49:30 2005
@@ -41,129 +41,123 @@
* the order To then Writer.
*/
public abstract class AbstractTransportSender extends AbstractHandler implements
- TransportSender {
- /**
- * Field log
- */
- private Log log = LogFactory.getLog(getClass());
-
-
-
- /**
- * Field NAME
- */
- public static final QName NAME = new QName("http://axis.ws.apache.org",
- "TransportSender");
-
- /**
- * Constructor AbstractTransportSender
- */
- public AbstractTransportSender() {
- init(new HandlerDescription(NAME));
- }
-
- public void init(ConfigurationContext confContext,
- TransportOutDescription transportOut) throws AxisFault {
-
- }
-
- /**
- * Method invoke
- *
- * @param msgContext
- * @throws AxisFault
- */
- public void invoke(MessageContext msgContext) throws AxisFault {
- //Check for the REST behaviour, if you desire rest beahaviour
- //put a <parameter name="doREST" value="true"/> at the axis2.xml
+ TransportSender {
+ /**
+ * Field log
+ */
+ private Log log = LogFactory.getLog(getClass());
+
+
+ /**
+ * Field NAME
+ */
+ public static final QName NAME = new QName("http://axis.ws.apache.org",
+ "TransportSender");
+
+ /**
+ * Constructor AbstractTransportSender
+ */
+ public AbstractTransportSender() {
+ init(new HandlerDescription(NAME));
+ }
+
+ public void init(ConfigurationContext confContext,
+ TransportOutDescription transportOut) throws AxisFault {
+
+ }
+
+ /**
+ * Method invoke
+ *
+ * @param msgContext
+ * @throws AxisFault
+ */
+ public void invoke(MessageContext msgContext) throws AxisFault {
+ //Check for the REST behaviour, if you desire rest beahaviour
+ //put a <parameter name="doREST" value="true"/> at the axis2.xml
msgContext.setDoingMTOM(HTTPTransportUtils.doWriteMTOM(msgContext));
- OutputStream out = null;
+ OutputStream out = null;
- EndpointReference epr = null;
+ EndpointReference epr = null;
- if (msgContext.getTo() != null
- && !AddressingConstants.Submission.WSA_ANONYMOUS_URL
- .equals(msgContext.getTo().getAddress())
- && !AddressingConstants.Final.WSA_ANONYMOUS_URL
- .equals(msgContext.getTo().getAddress())) {
- epr = msgContext.getTo();
- }
-
- if (epr != null) {
- out = openTheConnection(epr, msgContext);
- OutputStream newOut = startSendWithToAddress(msgContext, out);
- if (newOut != null) {
- out = newOut;
- }
- writeMessage(msgContext, out);
- finalizeSendWithToAddress(msgContext, out);
- } else {
- out = (OutputStream) msgContext
- .getProperty(MessageContext.TRANSPORT_OUT);
- if (out != null) {
- startSendWithOutputStreamFromIncomingConnection(msgContext, out);
- writeMessage(msgContext, out);
- finalizeSendWithOutputStreamFromIncomingConnection(msgContext,
- out);
- } else {
- throw new AxisFault(
- "Both the TO and Property MessageContext.TRANSPORT_WRITER is Null, No where to send");
- }
- }
- //TODO fix this, we do not set the value if the operation context is
- // not avalible
- if (msgContext.getOperationContext() != null) {
- msgContext.getOperationContext().setProperty(
- Constants.RESPONSE_WRITTEN, Constants.VALUE_TRUE);
- }
- }
-
- public void writeMessage(MessageContext msgContext, OutputStream out)
- throws AxisFault {
- SOAPEnvelope envelope = msgContext.getEnvelope();
- OMElement outputMessage = envelope;
-
- if (envelope != null && msgContext.isDoingREST()) {
- outputMessage = envelope.getBody().getFirstElement();
- }
-
- if (outputMessage != null) {
- OMOutput omOutput = null;
-
- try {
- if (msgContext.isDoingMTOM()) {
- omOutput = new OMOutput(out, true);
- outputMessage.serialize(omOutput);
- omOutput.flush();
+ if (msgContext.getTo() != null
+ && !AddressingConstants.Submission.WSA_ANONYMOUS_URL
+ .equals(msgContext.getTo().getAddress())
+ && !AddressingConstants.Final.WSA_ANONYMOUS_URL
+ .equals(msgContext.getTo().getAddress())) {
+ epr = msgContext.getTo();
+ }
+
+ if (epr != null) {
+ out = openTheConnection(epr, msgContext);
+ OutputStream newOut = startSendWithToAddress(msgContext, out);
+ if (newOut != null) {
+ out = newOut;
+ }
+ writeMessage(msgContext, out);
+ finalizeSendWithToAddress(msgContext, out);
+ } else {
+ out = (OutputStream) msgContext
+ .getProperty(MessageContext.TRANSPORT_OUT);
+ if (out != null) {
+ startSendWithOutputStreamFromIncomingConnection(msgContext, out);
+ writeMessage(msgContext, out);
+ finalizeSendWithOutputStreamFromIncomingConnection(msgContext,
+ out);
+ } else {
+ throw new AxisFault("Both the TO and Property MessageContext.TRANSPORT_WRITER is Null, No where to send");
+ }
+ }
+ //TODO fix this, we do not set the value if the operation context is
+ // not avalible
+ if (msgContext.getOperationContext() != null) {
+ msgContext.getOperationContext().setProperty(Constants.RESPONSE_WRITTEN, Constants.VALUE_TRUE);
+ }
+ }
+
+ public void writeMessage(MessageContext msgContext, OutputStream out)
+ throws AxisFault {
+ SOAPEnvelope envelope = msgContext.getEnvelope();
+ OMElement outputMessage = envelope;
+
+ if (envelope != null && msgContext.isDoingREST()) {
+ outputMessage = envelope.getBody().getFirstElement();
+ }
+
+ if (outputMessage != null) {
+ OMOutput omOutput = null;
+
+ try {
+ if (msgContext.isDoingMTOM()) {
+ omOutput = new OMOutput(out, true);
+ outputMessage.serialize(omOutput);
+ omOutput.flush();
omOutput.complete();
- out.flush();
- } else {
- omOutput = new OMOutput(out, false);
- outputMessage.serialize(omOutput);
- omOutput.flush();
- out.flush();
- }
- } catch (Exception e) {
- throw new AxisFault("Stream error", e);
- }
- } else {
- throw new AxisFault("the OUTPUT message is Null, nothing to write");
- }
- }
-
- public abstract OutputStream startSendWithToAddress(
- MessageContext msgContext, OutputStream out) throws AxisFault;
-
- public abstract void finalizeSendWithToAddress(MessageContext msgContext,
- OutputStream out) throws AxisFault;
+ out.flush();
+ } else {
+ omOutput = new OMOutput(out, false);
+ outputMessage.serialize(omOutput);
+ omOutput.flush();
+ out.flush();
+ }
+ } catch (Exception e) {
+ throw new AxisFault("Stream error", e);
+ }
+ } else {
+ throw new AxisFault("the OUTPUT message is Null, nothing to write");
+ }
+ }
+
+ public abstract OutputStream startSendWithToAddress(MessageContext msgContext, OutputStream out) throws AxisFault;
+
+ public abstract void finalizeSendWithToAddress(MessageContext msgContext,
+ OutputStream out) throws AxisFault;
- public abstract OutputStream startSendWithOutputStreamFromIncomingConnection(
- MessageContext msgContext, OutputStream out) throws AxisFault;
+ public abstract OutputStream startSendWithOutputStreamFromIncomingConnection(MessageContext msgContext, OutputStream out) throws AxisFault;
- public abstract void finalizeSendWithOutputStreamFromIncomingConnection(
- MessageContext msgContext, OutputStream out) throws AxisFault;
+ public abstract void finalizeSendWithOutputStreamFromIncomingConnection(MessageContext msgContext, OutputStream out) throws AxisFault;
- protected abstract OutputStream openTheConnection(EndpointReference epr,
- MessageContext msgctx) throws AxisFault;
+ protected abstract OutputStream openTheConnection(EndpointReference epr,
+ MessageContext msgctx) throws AxisFault;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/EmailReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/EmailReceiver.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/EmailReceiver.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/EmailReceiver.java Mon Jul 11 08:49:30 2005
@@ -24,9 +24,9 @@
/**
* @author hemapani
- *
- * To change the template for this generated type comment go to
- * Window>Preferences>Java>Code Generation>Code and Comments
+ * <p/>
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
*/
public class EmailReceiver {
@@ -43,12 +43,12 @@
this.popPort = popPort;
this.password = password;
}
-
-
- public void connect() throws AxisFault{
+
+
+ public void connect() throws AxisFault {
try {
final PasswordAuthentication authentication =
- new PasswordAuthentication(user, password);
+ new PasswordAuthentication(user, password);
Properties props = new Properties();
props.put("mail.user", user);
props.put("mail.host", host);
@@ -72,10 +72,10 @@
} catch (MessagingException e) {
throw new AxisFault(e);
}
-
+
}
-
- public void disconnect() throws AxisFault{
+
+ public void disconnect() throws AxisFault {
try {
inbox.close(true);
store.close();
@@ -83,10 +83,10 @@
throw new AxisFault(e);
}
}
-
+
public Message[] receive() throws AxisFault {
- try{
+ try {
inbox.open(Folder.READ_WRITE);
Message[] msgs = inbox.getMessages();
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportListener.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportListener.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportListener.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportListener.java Mon Jul 11 08:49:30 2005
@@ -27,9 +27,12 @@
public static final String PARAM_PORT = "port";
public abstract void init(ConfigurationContext axisConf, TransportInDescription transprtIn)
- throws AxisFault;
+ throws AxisFault;
+
public abstract void start() throws AxisFault;
+
public abstract void stop() throws AxisFault;
+
public abstract EndpointReference replyToEPR(String serviceName) throws AxisFault;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java Mon Jul 11 08:49:30 2005
@@ -26,5 +26,6 @@
*/
public interface TransportSender extends Handler {
public void cleanUp(MessageContext msgContext) throws AxisFault;
- public void init(ConfigurationContext confContext,TransportOutDescription transportOut)throws AxisFault;
+
+ public void init(ConfigurationContext confContext, TransportOutDescription transportOut) throws AxisFault;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java Mon Jul 11 08:49:30 2005
@@ -45,13 +45,13 @@
}
public static SOAPEnvelope createSOAPMessage(MessageContext msgContext, InputStream inStream)
- throws AxisFault {
+ throws AxisFault {
try {
Object contentType = null;
OperationContext opContext = msgContext.getOperationContext();
if (opContext != null) {
contentType = opContext.getProperty(HTTPConstants.MTOM_RECIVED_CONTENT_TYPE);
- }else{
+ } else {
throw new AxisFault("Operation Context can not be Null");
}
@@ -60,12 +60,12 @@
if (contentType != null) {
msgContext.setDoingMTOM(true);
- builder = HTTPTransportUtils.selectBuilderForMIME(msgContext, inStream, (String)contentType);
+ builder = HTTPTransportUtils.selectBuilderForMIME(msgContext, inStream, (String) contentType);
envelope = (SOAPEnvelope) builder.getDocumentElement();
- }else if (msgContext.isDoingREST()) {
+ } else if (msgContext.isDoingREST()) {
Reader reader = new InputStreamReader(inStream);
XMLStreamReader xmlreader =
- XMLInputFactory.newInstance().createXMLStreamReader(reader);
+ XMLInputFactory.newInstance().createXMLStreamReader(reader);
SOAPFactory soapFactory = new SOAP11Factory();
builder = new StAXOMBuilder(xmlreader);
builder.setOmbuilderFactory(soapFactory);
@@ -74,7 +74,7 @@
} else {
Reader reader = new InputStreamReader(inStream);
XMLStreamReader xmlreader =
- XMLInputFactory.newInstance().createXMLStreamReader(reader);
+ XMLInputFactory.newInstance().createXMLStreamReader(reader);
builder = new StAXSOAPModelBuilder(xmlreader);
envelope = (SOAPEnvelope) builder.getDocumentElement();
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java?rev=210150&r1=210149&r2=210150&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java Mon Jul 11 08:49:30 2005
@@ -30,7 +30,6 @@
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.xml.namespace.QName;
-
import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
@@ -77,21 +76,19 @@
* @throws ServletException
* @throws IOException
*/
- protected void doGet(
- HttpServletRequest httpServletRequest,
- HttpServletResponse httpServletResponse)
+ protected void doGet(HttpServletRequest httpServletRequest,
+ HttpServletResponse httpServletResponse)
throws ServletException, IOException {
httpServletResponse.setContentType("text/xml; charset=utf-8");
- MessageContext msgContext = null;
- OutputStream out =null;
+ MessageContext msgContext = null;
+ OutputStream out = null;
try {
Object sessionContext =
httpServletRequest.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
if (sessionContext == null) {
sessionContext = new SessionContext(null);
- httpServletRequest.getSession().setAttribute(
- Constants.SESSION_CONTEXT_PROPERTY,
- sessionContext);
+ httpServletRequest.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY,
+ sessionContext);
}
Enumeration enu = httpServletRequest.getParameterNames();
@@ -103,35 +100,31 @@
}
msgContext =
- new MessageContext(
- configContext,
- (SessionContext) sessionContext,
- configContext.getAxisConfiguration().getTransportIn(
- new QName(Constants.TRANSPORT_HTTP)),
- configContext.getAxisConfiguration().getTransportOut(
- new QName(Constants.TRANSPORT_HTTP)));
+ new MessageContext(configContext,
+ (SessionContext) sessionContext,
+ configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
+ configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
msgContext.setDoingREST(true);
msgContext.setServerSide(true);
- msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,new ServletBasedOutTransportInfo(httpServletResponse));
+ msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo, new ServletBasedOutTransportInfo(httpServletResponse));
out = httpServletResponse.getOutputStream();
boolean processed =
- HTTPTransportUtils.processHTTPGetRequest(
- msgContext,
- httpServletRequest.getInputStream(),
- out,
- httpServletRequest.getContentType(),
- httpServletRequest.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
- httpServletRequest.getRequestURL().toString(),
- configContext,
- map);
+ HTTPTransportUtils.processHTTPGetRequest(msgContext,
+ httpServletRequest.getInputStream(),
+ out,
+ httpServletRequest.getContentType(),
+ httpServletRequest.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
+ httpServletRequest.getRequestURL().toString(),
+ configContext,
+ map);
if (!processed) {
- lister.handle(httpServletRequest, httpServletResponse,out);
+ lister.handle(httpServletRequest, httpServletResponse, out);
}
} catch (Exception e) {
AxisEngine engine = new AxisEngine(configContext);
- if(msgContext!= null){
+ if (msgContext != null) {
msgContext.setProperty(MessageContext.TRANSPORT_OUT, out);
- engine.handleFault(msgContext,e);
+ engine.handleFault(msgContext, e);
}
}
@@ -161,32 +154,28 @@
req.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY, sessionContext);
}
msgContext =
- new MessageContext(
- configContext,
- (SessionContext) sessionContext,
- configContext.getAxisConfiguration().getTransportIn(
- new QName(Constants.TRANSPORT_HTTP)),
- configContext.getAxisConfiguration().getTransportOut(
- new QName(Constants.TRANSPORT_HTTP)));
- msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,new ServletBasedOutTransportInfo(res));
+ new MessageContext(configContext,
+ (SessionContext) sessionContext,
+ configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
+ configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
+ msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo, new ServletBasedOutTransportInfo(res));
res.setContentType("text/xml; charset=utf-8");
- HTTPTransportUtils.processHTTPPostRequest(
- msgContext,
- req.getInputStream(),
- res.getOutputStream(),
- req.getContentType(),
- req.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
- req.getRequestURL().toString(),
- configContext);
+ HTTPTransportUtils.processHTTPPostRequest(msgContext,
+ req.getInputStream(),
+ res.getOutputStream(),
+ req.getContentType(),
+ req.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
+ req.getRequestURL().toString(),
+ configContext);
Object contextWritten = msgContext.getOperationContext().getProperty(Constants.RESPONSE_WRITTEN);
if (contextWritten == null || !Constants.VALUE_TRUE.equals(contextWritten)) {
res.setStatus(HttpServletResponse.SC_ACCEPTED);
}
} catch (AxisFault e) {
AxisEngine engine = new AxisEngine(configContext);
- if(msgContext!= null){
+ if (msgContext != null) {
msgContext.setProperty(MessageContext.TRANSPORT_OUT, res.getOutputStream());
- engine.handleFault(msgContext,e);
+ engine.handleFault(msgContext, e);
}
}
}