[esb-java-dev] svn commit r24386 - branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders

[asankaa at wso2.com]

Author: asankaa
Date: Thu Nov 20 11:23:13 2008
New Revision: 24386
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24386

Log:
correct the typo


Added:
   branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java
      - copied, changed from r24385, /branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponceMessageBuilder.java
Removed:
   branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponceMessageBuilder.java

Deleted: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponceMessageBuilder.java
URL: http://wso2.org/svn/browse/wso2/None?pathrev=24385

Copied: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java (from r24385, /branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponceMessageBuilder.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=24386&r1=24385&r2=24386&view=diff
==============================================================================
--- /branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponceMessageBuilder.java	(original)
+++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java	Thu Nov 20 11:23:13 2008
@@ -1,12 +1,18 @@
 package org.apache.synapse.eventing.builders;
 
 import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
 import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMNamespace;
 import org.apache.axiom.soap.SOAPFactory;
 import org.apache.axiom.soap.SOAPEnvelope;
 import org.apache.synapse.eventing.Subscription;
+import org.apache.synapse.SynapseException;
 import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.addressing.EndpointReferenceHelper;
+import org.apache.axis2.addressing.AddressingConstants;
+import org.apache.axis2.AxisFault;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.wso2.eventing.EventingConstants;
 
 import javax.xml.namespace.QName;
@@ -29,17 +35,46 @@
 *  specific language governing permissions and limitations
 *  under the License.
 */
-public class ResponceMessageBuilder {
+public class ResponseMessageBuilder {
     private SOAPFactory factory;
-    public ResponceMessageBuilder(){
+    private static final Log log = LogFactory.getLog(ResponseMessageBuilder.class);
+    public ResponseMessageBuilder(){
         factory =(SOAPFactory) OMAbstractFactory.getOMFactory();
     }
+
+    /**
+     * Generate the subscription responce message
+     * @param subscription
+     * @return
+     */
     public SOAPEnvelope genSunscriptionResponce(Subscription subscription){
         SOAPEnvelope message = factory.getDefaultEnvelope();
         EndpointReference subscriptionManagerEPR = new EndpointReference("http://localhost:8280/soap/eventing"); //TODO: add subscription url to subscription object
         subscriptionManagerEPR.addReferenceParameter(new QName(EventingConstants.WSE_EVENTING_NS,
-                "Identifier", EventingConstants.WSE_EVENTING_PREFIX),subscription.getId());
-        
+                EventingConstants.WSE_EN_IDENTIFIER, EventingConstants.WSE_EVENTING_PREFIX),subscription.getId());
+        OMNamespace eventingNamespace = factory.createOMNamespace(EventingConstants.WSE_EVENTING_NS,
+                                                    EventingConstants.WSE_EVENTING_PREFIX);
+        OMElement subscribeResponseElement = factory.createOMElement(EventingConstants.WSE_EN_SUBSCRIBE_RESPONSE, eventingNamespace);
+        try {
+            OMElement subscriptionManagerElement = EndpointReferenceHelper.toOM(
+                        subscribeResponseElement.getOMFactory(),
+                        subscriptionManagerEPR,
+                        new QName(EventingConstants.WSE_EVENTING_NS,
+                                  EventingConstants.WSE_EN_SUBSCRIPTION_MANAGER,
+                                  EventingConstants.WSE_EVENTING_PREFIX),
+                        AddressingConstants.Submission.WSA_NAMESPACE);
+        } catch (AxisFault axisFault) {
+            handleException("unable to create subscription response",axisFault);
+        }
         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);
+    }
 }