Example: Using the AsapSink Component

Associate the FilePollSource (reader) component with the AsapSink (writer) component. The FilePollSource component reads records from file on the disk (insert.txt) and transfers those records to the AsapSink component. The AsapSink component then publishes those records to Event Stream Processor.

  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 sybase.
    UNIX
    1. Edit the set_example_env.sh script
    2. Set the ADAPTER_EXAMPLE_USERNAME and ADAPTER_EXAMPLE_PASSWORD variables to sybase.
  2. Start Event Stream Processor.
    Operating System Step
    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
    UNIX Open a terminal window:
    1. Start the example cluster:

      ./start_server_cluster.sh

    2. Start the project on the cluster:

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

    esp-subscribe.bat
    UNIX Open a terminal window and enter:

    ./esp-subscribe.sh
  4. Start the FilePollSource and AsapSink components.
    Operating System Step
    UNIX Open a terminal window and enter:

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

    fileToAsap.bat
    The FilePollSource components reads from the insert.txt file and passes records to AsapSink to publish to the Server.
  5. In the fileToAsap.props file, change adaptor.FILESOURCE.InputFileName to insert_withNULL.txt, and run again.
Parent topic: Examples
Related reference
AsapSink Properties