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/03/30 21:58:17 UTC
svn commit: r760135 - in
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing:
SynapseEventSource.java SynapseEventingConstants.java
Author: asanka
Date: Mon Mar 30 19:58:16 2009
New Revision: 760135
URL: http://svn.apache.org/viewvc?rev=760135&view=rev
Log:
Add new constants, rename the subscription operation to event operation.
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/SynapseEventingConstants.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=760135&r1=760134&r2=760135&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 Mon Mar 30 19:58:16 2009
@@ -85,18 +85,20 @@
eventSourceService.setName(this.name);
AxisOperation mediateOperation =
new InOutAxisOperation(SynapseConstants.SYNAPSE_OPERATION_NAME);
- AxisOperation subscribeOperation = new InOutAxisOperation(new QName("subscribe"));
+ AxisOperation eventOperation = new InOutAxisOperation(new QName("subscribe"));
mediateOperation.setMessageReceiver(this);
- subscribeOperation.setMessageReceiver(this);
- subscribeOperation.setSoapAction(EventingConstants.WSE_SUBSCRIBE);
+ eventOperation.setMessageReceiver(this);
+ eventOperation.setSoapAction(EventingConstants.WSE_SUBSCRIBE);
eventSourceService.addOperation(mediateOperation);
- eventSourceService.addOperation(subscribeOperation);
+ eventSourceService.addOperation(eventOperation);
axisCfg.addService(eventSourceService);
//Set the service parameters
- eventSourceService.addParameter("subscriptionManager", subscriptionManager);
- eventSourceService.addParameter("serviceType", "eventing");
+ eventSourceService
+ .addParameter(EventingConstants.SUBSCRIPTION_MANAGER, subscriptionManager);
+ eventSourceService.addParameter(SynapseEventingConstants.SERVICE_TYPE,
+ SynapseEventingConstants.EVENTING_ST);
}
/**
@@ -135,7 +137,7 @@
dispatchEvents(smc);
}
} catch (EventException e) {
- handleException("Subscription manager processing error",e);
+ handleException("Subscription manager processing error", e);
}
}
@@ -177,7 +179,7 @@
try {
subscribers = subscriptionManager.getMatchingSubscriptions(event);
} catch (EventException e) {
- handleException("Matching subscriptions fetching error",e);
+ handleException("Matching subscriptions fetching error", e);
}
// Call event dispatcher
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventingConstants.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventingConstants.java?rev=760135&r1=760134&r2=760135&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventingConstants.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventingConstants.java Mon Mar 30 19:58:16 2009
@@ -25,5 +25,7 @@
public class SynapseEventingConstants {
public static final String TOPIC_FILTER_DIALECT =
"http://synapse.apache.org/eventing/dialect/topicFilter";
- public static final String STATIC_ENTRY = "staticEntry";
+ public static final String STATIC_ENTRY = "staticEntry";
+ public static final String SERVICE_TYPE = "serviceType";
+ public static final String EVENTING_ST = "eventing";
}