[esb-java-dev] svn commit r24387 - in 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:47:15 2008
New Revision: 24387
URL: http://wso2.org/svn/browse/wso2?view=rev&revision=24387

Log:
invoke builder


Modified:
   branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java
   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/EventingMessageReceiver.java
URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java?rev=24387&r1=24386&r2=24387&view=diff
==============================================================================
--- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java	(original)
+++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/EventingMessageReceiver.java	Thu Nov 20 11:47:15 2008
@@ -22,11 +22,13 @@
 import org.apache.axis2.AxisFault;
 import org.apache.axis2.context.MessageContext;
 import org.apache.synapse.SynapseConstants;
+import org.apache.synapse.eventing.builders.ResponseMessageBuilder;
 import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.core.SynapseEnvironment;
 import org.apache.synapse.core.axis2.Axis2MessageContext;
 import org.apache.synapse.core.axis2.SynapseMessageReceiver;
 import org.apache.synapse.util.MessageHelper;
+import org.apache.axiom.soap.SOAPEnvelope;
 import org.wso2.eventing.EventingConstants;
 import java.util.List;
 
@@ -50,6 +52,8 @@
         if (EventingConstants.WSE_SUBSCRIBE.equals(mc.getWSAAction())) {
             Subscription subscription = SubscriptionFactory.createSubscription(smc);
             eventSource.getSubscriptionManager().addSubscription(subscription);
+            ResponseMessageBuilder messageBuilder = new ResponseMessageBuilder();
+            SOAPEnvelope soapEnvelope = messageBuilder.genSubscriptionResponse(subscription);
             String replyAddress = mc.getOptions().getTo().getAddress();
         } else {
             List<Subscription> subscribers = eventSource.getSubscriptionManager().getMatchingSubscribers(smc);

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=24387&r1=24386&r2=24387&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	Thu Nov 20 11:47:15 2008
@@ -11,6 +11,7 @@
 import org.apache.axis2.addressing.EndpointReferenceHelper;
 import org.apache.axis2.addressing.AddressingConstants;
 import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.wso2.eventing.EventingConstants;
@@ -47,7 +48,7 @@
      * @param subscription
      * @return
      */
-    public SOAPEnvelope genSunscriptionResponce(Subscription subscription){
+    public SOAPEnvelope genSubscriptionResponse(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,
@@ -63,6 +64,8 @@
                                   EventingConstants.WSE_EN_SUBSCRIPTION_MANAGER,
                                   EventingConstants.WSE_EVENTING_PREFIX),
                         AddressingConstants.Submission.WSA_NAMESPACE);
+                subscribeResponseElement.addChild(subscriptionManagerElement);
+                message.getBody().addChild(subscribeResponseElement);
         } catch (AxisFault axisFault) {
             handleException("unable to create subscription response",axisFault);
         }