basic.ForkPush Class Reference

Use the Fork processor to replicate input events in multiple output streams. More...

Static Public Member Functions
static void	main (String[] args) throws InterruptedException

Detailed Description

Use the Fork processor to replicate input events in multiple output streams.

Graphically, the processors of this example can be drawn as follows:

The expected output of this program is:

P0 foo
P1 foo
P2 foo
P0 bar
P1 bar
P2 bar

Author

Sylvain Hallé Easy

Definition at line 47 of file ForkPush.java.

---

The documentation for this class was generated from the following file:

• Source/src/basic/ForkPush.java