in modules/core/src/main/java/org/apache/sandesha2/RMMsgContext.java [513:571]
private void processBody(SOAPBody body) throws AxisFault{
if(bodyLocalNames.contains(body.getFirstElementLocalName())){
// The body messages
OMElement firstBodyElement = body.getFirstElement();
if(firstBodyElement != null) {
QName firstBodyQName = firstBodyElement.getQName();
String namespace = firstBodyQName.getNamespaceURI();
boolean isSPEC2007_02 = SPEC_2007_02.NS_URI.equals(namespace);
boolean isSPEC2005_02 = false;
if(!isSPEC2007_02){
isSPEC2005_02 = SPEC_2005_02.NS_URI.equals(namespace);
}
if(isSPEC2005_02 || isSPEC2007_02){
if(Sandesha2Constants.SPEC_2007_02.QNames.CreateSequence.equals(firstBodyQName)) {
createSequence = new CreateSequence(namespace);
createSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.CreateSequence.equals(firstBodyQName)) {
createSequence = new CreateSequence(namespace);
createSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2007_02.QNames.CreateSequenceResponse.equals(firstBodyQName)) {
createSequenceResponse = new CreateSequenceResponse(namespace);
createSequenceResponse.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.CreateSequenceResponse.equals(firstBodyQName)) {
createSequenceResponse = new CreateSequenceResponse(namespace);
createSequenceResponse.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2007_02.QNames.CloseSequence.equals(firstBodyQName)) {
closeSequence = new CloseSequence(namespace);
closeSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.CloseSequence.equals(firstBodyQName)) {
closeSequence = new CloseSequence(namespace);
closeSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2007_02.QNames.CloseSequenceResponse.equals(firstBodyQName)) {
closeSequenceResponse = new CloseSequenceResponse(namespace);
closeSequenceResponse.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.CloseSequenceResponse.equals(firstBodyQName)) {
closeSequenceResponse = new CloseSequenceResponse(namespace);
closeSequenceResponse.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2007_02.QNames.TerminateSequence.equals(firstBodyQName)) {
terminateSequence = new TerminateSequence(namespace);
terminateSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.TerminateSequence.equals(firstBodyQName)) {
terminateSequence = new TerminateSequence(namespace);
terminateSequence.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2007_02.QNames.TerminateSequenceResponse.equals(firstBodyQName)) {
terminateSequenceResponse = new TerminateSequenceResponse(namespace);
terminateSequenceResponse.fromOMElement(body);
} else if(Sandesha2Constants.SPEC_2005_02.QNames.TerminateSequenceResponse.equals(firstBodyQName)) {
terminateSequenceResponse = new TerminateSequenceResponse(namespace);
terminateSequenceResponse.fromOMElement(body);
}
}else if(Sandesha2Constants.SPEC_2007_02.QNames.MakeConnection.equals(firstBodyQName)) {
makeConnection = new MakeConnection();
makeConnection.fromOMElement(firstBodyElement);
}
}
}
}