Skip to end of metadata
Go to start of metadata

You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 6 Next »

This sample demonstrates the real-time analytics features of WSO2 BAM, by using the integrated WSO2 CEP features.

Creating an event stream

Follow the steps below to create a new event stream.

  1. Log in to the WSO2 BAM management console.
  2. Click Main, and then click Event Streams.
  3. Click Add Event Stream.
  4. Enter org.wso2.sample.rt.traffic for Event Stream Name, and enter 1.0.0 for Event Stream Version.
  5. Enter the following values for Payload Data Attributes under Stream Attributes and click Add.
    • Attribute Name  entry
    • Attribute Type string
  6. Click Add Event Stream.
  7. Select Default WSO2Event Builder in the message that pops up, and click OK.

Creating HTTP event output adaptor

Follow the steps below to create a HTTP event output adaptor.

  1. In the BAM management console click Configure, and then click Output Event Adaptors.
  2. Click Add Output Event Adaptor.
  3. Enter HTTP for Event Adaptor Name and select http for Event Adaptor Type.
  4. Click Add Event Adaptor.

Creating the execution plan

Follow the steps below to create a new execution plan.

  1. In the BAM management console click Main, and then click Execution Plans.
  2. Click Add Execution Plan.
  3. Enter rt_traffic_plan for Execution Plan Name.
  4. Under Import Stream select org.wso2.sample.rt.traffic for Import Stream, and enter traffic for As.
  5. Click Import.
  6. Enter the following query expression in the provided space:
    from traffic#window.time(1 sec) select count(entry) as entryCount insert into traffic_out;
  7. Under Export Stream, enter traffic_out for Value of, and select org.wso2.sample.rt.traffic for StreamId.
  8. Click Add Execution Plan.


    • Export Stream, value of="traffic_out", streamId="–Create Stream Definition–" -> Use defaults -> Select "traffic_out:1.0.0"
      • Event Formatter -> "Custom Event Formatter"
        • Event formatter; name="rt_traffic_formatter", stream="traffic_out:1.0.0", output event adaptor="http_adaptor", output mapping="text"
        • output event adaptor name="HTTP"
        • output mapping content="{{entryCount}}"
        • url="https://localhost:9443/message_store?type=RT_SAMPLE_STATS"
        • username="admin", password="admin"
      • Add
  • Goto the BAM admin console, and goto "BAM Toolbox" -> Add -> Realtime Traffic Monitoring Toolbox -> Install
  • After the above actions are done, from a command line console, navigate to $BAM_SERVER/samples/rt-traffic, and type "ant". This will start executing a data publisher, and will be sending data continuously, the data rate of the items published here is happening randomly.
  • Navigate to "https://$host:9443/bamdashboards/rt_traffic/stats.jag" (here $host must be the exact host the server has started up, testing with "localhost" may not work, because of browser cross domain limitations). Now here, you will see a line graph being updated in real-time to show the frequency of the messages being published at that time.

  • No labels