blob: 0b5451b5676f8d753c77080ec24a0ea34af6acc8 [file] [log] [blame]
package org.apache.kandula.wscoor;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
import org.apache.kandula.context.AbstractContext;
import org.apache.kandula.context.at.ATActivityContext;
import org.apache.kandula.initiator.TransactionManager;
import org.apache.kandula.storage.StorageFactory;
import org.apache.kandula.utility.KandulaUtils;
/*
* Copyright 2004,2005 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*
*/
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
*/
public class RegistrationRequesterPortTypeRawXMLSkeleton {
private MessageContext msgContext;
public void init(MessageContext context) {
this.msgContext = context;
}
public OMElement registerResponseOperation(OMElement responseElement) {
OMElement response = responseElement.getFirstElement();
if ("CoordinatorProtocolService".equals(response.getLocalName())) {
EndpointReference coordinatorService = KandulaUtils
.endpointFromOM(response.getFirstElement());
AbstractContext context = (AbstractContext) StorageFactory
.getInstance().getStore().get(TransactionManager.tempID);
context.setProperty(ATActivityContext.COORDINATION_EPR,
coordinatorService);
}
return null;
}
}