Configuring the stream

Stream DSL can be used to configure a stream--a simple example has been shown here to connect app1 to app2. The messages put on the output channel by app1 will be received on the input channel of app2:

app1 | app2

We would want to connect the three applications. The following snippet shows an example of a DSL used to connect the preceding applications:

#source | processor | sink

significant-stock-change-source|stock-intelligence-processor|event-store-sink

This indicates the following:

  • The output channel of the source should be linked to the input channel of processor
  • The output channel of the processor should be linked to the input channel of sink

The entire command to create a stream is shown as follows:

stream create --name process-stock-change-events --definition significant-stock-change-source|stock-intelligence-processor|event-store-sink

You should see the following output if the stream is successfully created:

Created new stream 'process-stock-change-events'

You can also see the registered stream on the Streams tab of Spring Cloud Data Flow dashboard at http://localhost:9393/dashboard, as shown in the following screenshot:

..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.
Reset