Example: Using the WSSink Component

Use the WsSink.props file to associate the WSSink component with the AsapSource component. AsapSource reads data from the Server and passes records to WSSink, which publishes these records to a Web service. A second WsSource.props file associates the WSSource component with FileSink. WSSource reads published records to the Web service and passes them to FileSink, which writes those records to file.

  1. Start Event Stream Processor.
    Operating System Step
    UNIX Open a terminal window:
    1. Start the example cluster:

      start_server_cluster.sh

    2. Start the project on the cluster:

      start_project.sh
    Windows Open a command window:
    1. Start the example cluster:

      start_server_cluster.bat

    2. Add project to the cluster, and start it on the cluster:

      start_project.bat
  2. Start esp_subscriber to subscribe to the project that is running on the cluster.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./esp-subscribe.sh
    Windows Open a command window and enter:

    esp-subscribe.bat
  3. Call the esp_upload command, and upload records to the Server.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./upload.sh
    Windows Open a command window and enter:

    upload.bat
  4. Start the WSSource and FileSink components, and the Web service they are connected to.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./WsSource.sh
    Windows Open a command window and enter:

    WsSource.bat
  5. Start the WSSink with AsapSource components.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./WsSink.sh
    Windows Open a command window and enter:

    WsSink.bat
    The out_wssource.txt file now contains records. WSSink reads the uploaded records and passes them to the Web service. WSSource reads these records and passes them to FileSink, which writes them to the out_wssource.txt file.
Parent topic: Examples
Related reference
WSSink Properties