...
- First, we need to define a new S4 subcluster for that app:
Code Block S4:myApp$ ./s4 newCluster -c=cluster2 -nbTasks=1 -flp=13000
- Then we can start the adapter, and we use "names" for identifying the output stream (this is the same name used as input by the myApp app)
Code Block ./s4 adapter -appClass=hello.HelloInputAdapter -c=cluster2 -namedStringParameters=adapter.output.stream:names
- Now let's just provide some data to the external stream:
Code Block S4:~$ echo "Bob" | nc localhost 15000
- One of the node nodes should output in its console:
Code Block Hello Bob!
...