Author: asankaa Date: Mon Nov 24 10:31:23 2008 New Revision: 24744 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24744
Log: complete the response message stubs Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java?rev=24744&r1=24743&r2=24744&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java (original) +++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java Mon Nov 24 10:31:23 2008 @@ -5,6 +5,7 @@ import org.apache.axiom.soap.SOAPEnvelope; import org.apache.axiom.soap.SOAPFactory; import org.apache.axis2.AxisFault; +import org.apache.axis2.databinding.utils.ConverterUtil; import org.apache.axis2.addressing.AddressingConstants; import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.addressing.EndpointReferenceHelper; @@ -40,8 +41,7 @@ private static final Log log = LogFactory.getLog(ResponseMessageBuilder.class); public ResponseMessageBuilder(MessageContext messageCtx) { - factory = (SOAPFactory) messageCtx.getEnvelope().getOMFactory(); - //factory =(SOAPFactory) OMAbstractFactory.getOMFactory(); + factory = (SOAPFactory) messageCtx.getEnvelope().getOMFactory(); } /** @@ -106,16 +106,6 @@ return message; } - private void handleException(String message) { - log.error(message); - throw new SynapseException(message); - } - - private void handleException(String message, Exception e) { - log.error(message, e); - throw new SynapseException(message, e); - } - /** * (01) <s12:Envelope * (02) xmlns:s12="http://www.w3.org/2003/05/soap-envelope"; @@ -137,10 +127,6 @@ */ public SOAPEnvelope genUnSubscribeResponse(Subscription subscription) { SOAPEnvelope message = factory.getDefaultEnvelope(); - OMNamespace addressNamespace = factory.createOMNamespace("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "wsa"); - OMElement relateToElement = factory.createOMElement("RelatesTo", addressNamespace); - factory.createOMText(relateToElement, subscription.getId()); - message.getHeader().addChild(relateToElement); OMElement dummyBody = factory.createOMElement("UnSunscribeResponce", null); message.getBody().addChild(dummyBody); return message; @@ -173,7 +159,12 @@ */ public SOAPEnvelope genRenewSubscriptionResponse(Subscription subscription) { SOAPEnvelope message = factory.getDefaultEnvelope(); - //TODO : build message stub + OMNamespace eventingNamespace = factory.createOMNamespace(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EVENTING_PREFIX); + OMElement renewResponseElement = factory.createOMElement(EventingConstants.WSE_EN_RENEW_RESPONSE, eventingNamespace); + OMElement expiresElement = factory.createOMElement(EventingConstants.WSE_EN_EXPIRES, eventingNamespace); + factory.createOMText(expiresElement, ConverterUtil.convertToString(subscription.getExpires())); + renewResponseElement.addChild(expiresElement); + message.getBody().addChild(renewResponseElement); return message; } @@ -204,7 +195,23 @@ */ public SOAPEnvelope genGetStatusResponse(Subscription subscription) { SOAPEnvelope message = factory.getDefaultEnvelope(); - //TODO : build message stub + OMNamespace eventingNamespace = factory.createOMNamespace(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EVENTING_PREFIX); + OMElement renewResponseElement = factory.createOMElement(EventingConstants.WSE_EN_GET_STATUS_RESPONSE, eventingNamespace); + OMElement expiresElement = factory.createOMElement(EventingConstants.WSE_EN_EXPIRES, eventingNamespace); + factory.createOMText(expiresElement, ConverterUtil.convertToString(subscription.getExpires())); + renewResponseElement.addChild(expiresElement); + message.getBody().addChild(renewResponseElement); return message; } + + private void handleException(String message) { + log.error(message); + throw new SynapseException(message); + } + + private void handleException(String message, Exception e) { + log.error(message, e); + throw new SynapseException(message, e); + } + } _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
