Author: asankaa Date: Sun Jan 4 21:54:21 2009 New Revision: 27915 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=27915
Log: Fixing CARBON-2009 Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java?rev=27915&r1=27914&r2=27915&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java (original) +++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscription.java Sun Jan 4 21:54:21 2009 @@ -34,6 +34,7 @@ private SynapseEventFilter filter; private Endpoint endpoint; private boolean staticEntry; + private String subManagerURI; public SynapseSubscription() { this.setId(UUIDGenerator.getUUID()); this.setDeliveryMode(EventingConstants.WSE_DEFAULT_DELIVERY_MODE); @@ -68,4 +69,12 @@ public void setStaticEntry(boolean staticEntry) { this.staticEntry = staticEntry; } + + public String getSubManagerURI() { + return subManagerURI; + } + + public void setSubManagerURI(String subManagerURI) { + this.subManagerURI = subManagerURI; + } } 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=27915&r1=27914&r2=27915&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 Sun Jan 4 21:54:21 2009 @@ -84,7 +84,7 @@ */ public SOAPEnvelope genSubscriptionResponse(SynapseSubscription subscription) { SOAPEnvelope message = factory.getDefaultEnvelope(); - EndpointReference subscriptionManagerEPR = new EndpointReference(subscription.getAddressUrl()); + EndpointReference subscriptionManagerEPR = new EndpointReference(subscription.getSubManagerURI()); subscriptionManagerEPR.addReferenceParameter(new QName(EventingConstants.WSE_EVENTING_NS, EventingConstants.WSE_EN_IDENTIFIER, EventingConstants.WSE_EVENTING_PREFIX), subscription.getId()); OMNamespace eventingNamespace = factory.createOMNamespace(EventingConstants.WSE_EVENTING_NS, Modified: branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java?rev=27915&r1=27914&r2=27915&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java (original) +++ branches/synapse/1.2.wso2v1/modules/core/src/main/java/org/apache/synapse/eventing/builders/SubscriptionMessageBuilder.java Sun Jan 4 21:54:21 2009 @@ -131,6 +131,7 @@ subscription.setEndpoint(ep); subscription.setAddressUrl(notifyToElem.getFirstElement().getText()); subscription.setEndpointUrl(notifyToElem.getFirstElement().getText()); + subscription.setSubManagerURI(mc.getTo().getAddress()); } } else { handleException("NotifyTo element not found in the subscription message"); _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
