Examples are located at
$ESP_HOME/ESP-5_1/adapters/open_adaptor/examples.
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.
Example: Using the AsapSource Component
Associate the AsapSource (reader) component with the FileSink (writer) component. AsapSource reads records from Event Stream Processor and passes those to FileSink, which then writes those records to the out.txt file.
Example: Using the BeanShellPipe Component
You can use the BeanShellPipe component between the AsapSource and FileSink components. BeanShellPipe executes some commands in shell after it receives data from AsapSource, and before publishing data to FileSink.
Example: Using the JDBCLookupPipe Component
AsapSource reads data from Event Stream Processor and passes it to the JDBC lookup pipe. If required, the JDBC lookup pipe modifies the values of the 'charfield' column by using 'replaceValue1', and passes that data to FileSource, which then outputs that data to the file out.txt file.
Example: Using the MultiFlatXmlStringReader Component
Associate the MultiFlatXmlStringReader component with the FilePollSource component so that it can read records in XML format and pass them to AsapSink, which publishes them to the Server.
Example: Using the SpPersistentSubscribeSource Component
The SpPersistentSubscribeSource component subscribes to the Server using persistent subscribe (stores subscribed records until it processes them, and then deletes them).
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.
Example: Using the WSSource Component
Use the WSSource component to publish data to a Web service using a Web service client, such as soapUI. WSSource reads records from the Web service and passes them to FileSink, which writes those records to file.
Example: Using the XPathMultiTypeXmlReader Component
Associate the XPathMultiTypeXmlReader component with the FilePollSource component, which reads XML formatted data, and with the AsapSink component, which publishes records to the Server. Define parsing rules in the XPathXmlStreamReader.props file, and use these rules to parse XML records being read from file.
Example: Using the XPathXmlStreamReader Component
XPathXmlStreamReader parses a single row of data from a single XML input file and sends the row to the ESP project. Then, the esp-subscribe.sh (Linux, Solaris) or esp-subscribe.bat (Windows) file reads the row and displays it in the console.
Example: Using the XPathXmlStringWriter Component
The XPathXmlStringWriter component writes XML formatted data using XPath rules, and is used with the FileSink component. Associate the AsapSource component, which reads data from the Server and passes it to FileSink, with the FileSink component, which writes out the XML data using XPathXmlStringWriter.