Use file connectors to read Quote messages from a file, and publish
them to the Event Stream Processor. If the value of the OfferPx field is
less than 30.0, write a NewOrderSingle message to another 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.
Context
Figure 1:
File Connectors
Procedure
- Set the user name and password in the example environment:
| Operating System |
Step |
|---|
| Windows |
- Edit the set_example_env.bat script
- Set the ADAPTER_EXAMPLE_USERNAME and ADAPTER_EXAMPLE_PASSWORD
variables to the desired user name/password combination.
- If SSL is enabled, set
ADAPTER_EXAMPLE_CLUSTER_NODE_PROTOCOL to esps. If it is
disabled, set it to esp.
|
| UNIX |
- Edit the set_example_env.sh script
- Set the ADAPTER_EXAMPLE_USERNAME and ADAPTER_EXAMPLE_PASSWORD
variables to the desired user name/password combination.
- If SSL is enabled, set
ADAPTER_EXAMPLE_CLUSTER_NODE_PROTOCOL to esps. If it is
disabled, set it to esp.
|
- Start SAP Event Stream Processor.
| Operating System |
Step |
|---|
| Windows |
Open a command window:- Start the cluster:
start_node.bat
- Add project to the cluster, and start it on the cluster:
start_project.bat
|
| UNIX |
Open a terminal window: - Start the cluster:
./start_node.sh
- Start the project on the cluster:
./start_project.sh
|
- Start the respective subscriber utility for
Event Stream Processor.
| Operating System |
Step |
|---|
| UNIX |
Open a terminal window and
enter: ./streamingsubscribe.sh
|
| Windows |
Open a command window and
enter: streamingsubscribe.bat
|
- Start the adapter.
| Operating System |
Step |
|---|
| Windows |
Open a command window and
enter: start_adapter.bat
|
| UNIX |
Open a terminal window and enter:
./start_adapter.sh
|
- Wait five to ten seconds for the adapter to initialize.
- The MyQuotes stream now contains two records. The MyOrders stream contains one
record. Use the Event Stream Processor subscriber utility to
view the content of the streams.
- The orders.fix file now contains a NewOrderSingle message.
