Mule Esper Example: Mule Configuration

mule-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:twitter="http://www.mulesoft.org/schema/mule/twitter"
      xmlns:quartz="http://www.mulesoft.org/schema/mule/quartz"
      
      xmlns:esper="http://www.mulesoft.org/schema/mule/esper"
      xsi:schemaLocation="
        http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.2/mule.xsd
        http://www.mulesoft.org/schema/mule/quartz http://www.mulesoft.org/schema/mule/quartz/3.2/mule-quartz.xsd
        http://www.mulesoft.org/schema/mule/bpm http://www.mulesoft.org/schema/mule/bpm/3.2/mule-bpm.xsd
        http://www.mulesoft.org/schema/mule/esper http://www.mulesoft.org/schema/mule/esper/1.0/mule-esper.xsd
        http://www.mulesoft.org/schema/mule/twitter http://www.mulesoft.org/schema/mule/twitter/2.3/mule-twitter.xsd
       ">

    <description>
        Esper Cloud Connector example using Twitter
    </description>

    <esper:config configuration="esper-config.xml"/>

    <twitter:config consumerKey="****************" consumerSecret="***************"/>

    <flow name="main">
        <poll frequency="120000">
            <twitter:get-public-timeline/>
        </poll>
        <twitter:get-public-timeline/>
        <collection-splitter/>
        <esper:send eventPayload-ref="#[payload:]"/>
    </flow>

    <flow name="Event Listener Flow">
        <esper:listen statement="select count(hashtagEntities.where(p => p.text = 'mule')) as tagged
            from Tweets having count(hashtagEntities.where(p => p.text = 'mule')) > 0"/>
        <logger category="INFO"/>
    </flow>
</mule>