Publishing Binary Events via TCP¶
Purpose:¶
This application demonstrates how to configure WSO2 Streaming Integrator Tooling to send sweet production events via TCP transport in binary format and view the output on the console.
Prerequisites:¶
Save this sample.
Executing the Sample:¶
- Open a terminal and navigate to the
{WSO2SIHome}/samples/sample-clients/tcp-server
directory. Run the command:ant -Dcontext=LowProductionAlertStream
- Start the Siddhi application by clicking 'Run'.
- If the Siddhi application starts successfully, the following messages appear on the console.
* PublishTcpInBinaryFormat.siddhi - Started Successfully! * 'tcp' sink at 'LowProductionAlertStream' stream successfully connected to 'localhost:9892'.
- Open the event simulator by clicking on the second icon or press Ctrl+Shift+I.
- In the Single Simulation tab of the panel, select values as follows:
- Siddhi App Name: PublishTcpInBinaryFormat
- Stream Name: SweetProductionStream
- In the 'name' and 'amount' fields, enter 'toffee' and '45.24' respectively, and then click Send to send the event.
- Send some more events.
- Check the output in the terminal of {WSO2SIHome}/samples/sample-clients/tcp-server. You will see output similar to the following:
[java] [org.wso2.si.tcp.server.TCPServer] : Event{timestamp=1512446413468, data=[toffee, 45.25], isExpired=false} [java] [org.wso2.si.tcp.server.TCPServer] : Event{timestamp=1512446425113, data=[coffee, 9.78], isExpired=false} [java] [org.wso2.si.tcp.server.TCPServer] : Event{timestamp=1512446442300, data=[chocolate, 78.23], isExpired=false}
Notes:¶
If you need to edit this application while it is running, stop the application -> Save -> Start.
If the message 'LowProducitonAlertStream' stream could not connect to 'localhost:9892'
, it could be due to port 9892, which is defined in the Siddhi application. This port is already being used by a different program. To resolve this issue, please do the following:
* Stop this Siddhi application (click 'Run' on menu bar -> 'Stop').
* Change the port 9892 to an unused port, in this Siddhi application's source configuration and also change the port number in the tcp-server file.
* Start the application and check whether the expected output appears on the console.
@App:name("PublishTcpInBinaryFormat")
@App:description('Send events via TCP transport using binary format')
define stream SweetProductionStream (name string, amount double);
@sink(type='tcp', url='tcp://localhost:9892/LowProductionAlertStream',
@map(type='binary'))
define stream LowProductionAlertStream (name string, amount double);
from SweetProductionStream
select *
insert into LowProductionAlertStream;
Top