You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by as...@apache.org on 2009/05/27 13:59:23 UTC

svn commit: r779126 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing: SynapseEventSource.java builders/ResponseMessageBuilder.java

Author: asanka
Date: Wed May 27 11:59:22 2009
New Revision: 779126

URL: http://svn.apache.org/viewvc?rev=779126&view=rev
Log:
Replace the SynapseSubscription by Subscription to avoide typecast.

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java?rev=779126&r1=779125&r2=779126&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java Wed May 27 11:59:22 2009
@@ -317,14 +317,13 @@
     private void processGetStatusRequest(MessageContext mc,
                                          ResponseMessageBuilder messageBuilder)
             throws AxisFault, EventException {
-        SynapseSubscription subscription =
+        Subscription subscription =
                 SubscriptionMessageBuilder.createGetStatusMessage(mc);
         if (log.isDebugEnabled()) {
             log.debug("GetStatus request recived for SynapseSubscription ID : " +
                     subscription.getId());
         }
-        subscription =
-                (SynapseSubscription) subscriptionManager.getSubscription(subscription.getId());
+        subscription = subscriptionManager.getSubscription(subscription.getId());
         if (subscription != null) {
             if (log.isDebugEnabled()) {
                 log.debug("Sending GetStatus responce for SynapseSubscription ID : " +

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java?rev=779126&r1=779125&r2=779126&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/builders/ResponseMessageBuilder.java Wed May 27 11:59:22 2009
@@ -15,6 +15,7 @@
 import org.apache.synapse.SynapseException;
 import org.apache.synapse.eventing.SynapseSubscription;
 import org.wso2.eventing.EventingConstants;
+import org.wso2.eventing.Subscription;
 
 import javax.xml.namespace.QName;
 
@@ -202,7 +203,7 @@
      * @param subscription
      * @return
      */
-    public SOAPEnvelope genGetStatusResponse(SynapseSubscription subscription) {
+    public SOAPEnvelope genGetStatusResponse(Subscription subscription) {
         SOAPEnvelope message = factory.getDefaultEnvelope();
         OMNamespace eventingNamespace = factory.createOMNamespace(EventingConstants.WSE_EVENTING_NS,
                 EventingConstants.WSE_EVENTING_PREFIX);