Sample 501: Event Source with Static Subscriptions
<definitions xmlns="http://ws.apache.org/ns/synapse">
<eventSource name="SampleEventSource">
<subscriptionManager
class="org.apache.synapse.eventing.managers.DefaultInMemorySubscriptionManager">
<!--property name="registryURL" value="http://localhost:8180/wso2registry"/>
<property name="username" value="admin"/>
<property name="password" value="admin"/-->
<property name="topicHeaderName" value="Topic"/>
<property name="topicHeaderNS" value="http://apache.org/aip"/>
</subscriptionManager>
<subscription id="mysub1">
<filter source="synapse/event/test"
dialect="http://synapse.apache.org/eventing/dialect/topicFilter"/>
<endpoint>
<address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
</endpoint>
</subscription>
<subscription id="mysub2">
<filter source="synapse/event/test"
dialect="http://synapse.apache.org/eventing/dialect/topicFilter"/>
<endpoint>
<address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
</endpoint>
<expires>2020-06-27T21:07:00.000-08:00</expires>
</subscription>
</eventSource>
<sequence name="PublicEventSource">
<log level="full"/>
<eventPublisher eventSourceName="SampleEventSource"/>
</sequence>
<proxy name="EventingProxy">
<target inSequence="PublicEventSource"/>
</proxy>
</definitions>
Pre-requisites
- Deploy the SimpleStockQuoteService in the sample Axis2 server and start Axis2
-
Start Synapse using the configuration numbered 501 (repository/conf/sample/synapse_sample_501.xml)
Unix/Linux: sh synapse.sh -sample 501
Windows: synapse.bat -sample 501
Executing the Client
In this sample configuration, two static subscriptions are created by providing the SimpleStockQuoteService as the event sink. To try this out, invoke the sample client as follows.
ant eventsender
Events will be mediated and sent to the sample Axis2 server as operated by the two static subscriptions.