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);