Show TOC

Example: Using the WSSink ComponentLocate this document in the navigation structure

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.

Prerequisites

The cluster database stores configuration information. Ensure that the cluster is running, so that the adapter can interact with the projects on the cluster.

Procedure

  1. Set the user name and password in the example environment:
    Operating System Step
    Windows
    1. Edit the set_example_env.bat script
    2. Set the ADAPTER_EXAMPLE_USERNAME and ADAPTER_EXAMPLE_PASSWORD variables to the desired user name/password combination.
    3. If SSL is enabled, set ADAPTER_EXAMPLE_CLUSTER_NODE_PROTOCOL to esps. If it is disabled, set it to esp.
    UNIX
    1. Edit the set_example_env.sh script
    2. Set the ADAPTER_EXAMPLE_USERNAME and ADAPTER_EXAMPLE_PASSWORD variables to the desired user name/password combination.
    3. If SSL is enabled, set ADAPTER_EXAMPLE_CLUSTER_NODE_PROTOCOL to esps. If it is disabled, set it to esp.
  2. Start SAP Event Stream Processor.
    Operating System Step
    Windows Open a command window:
    1. Start the cluster:

      start_server_cluster.bat

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

      start_project.bat

    UNIX Open a terminal window:
    1. Start the cluster:

      ./start_server_cluster.sh

    2. Start the project on the cluster:

      ./start_project.sh

  3. Start streamingsubscribe to subscribe to the project that is running on the cluster.
    Operating System Step
    Windows Open a command window and enter:

    streamingsubscribe.bat

    UNIX Open a terminal window and enter:

    ./streamingsubscribe.sh

  4. Call the streamingupload command, and upload records to the Server.
    Operating System Step
    UNIX Open a terminal window and enter:

    ./streamingupload.sh

    Windows Open a command window and enter:

    streamingupload.bat

  5. 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

  6. 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.