gistfile1.txt

<flow name="testFlow">
        <vm:inbound-endpoint path="in"/>
        <esper:send eventPayload-ref="#[payload:]"/>
        <vm:outbound-endpoint path="out"/>
    </flow>

    <flow name="Event Listener Flow">
        <esper:listen statement="select count(*) from TestEvent
                            .win:time_batch(5, 'FORCE_UPDATE, START_EAGER') having count(*) &gt; 0"/>
        <esper:get-event-property key="count(*)"/>
        <vm:outbound-endpoint path="events"/>
    </flow>