Two scenarios as below:
1. broadcast each node to wait for data from queue then put data to queue.
2. put data to queue then broadcast each node to read data from queue.
The example seems is second scenario.
Is first scenario possible to do ?
Thanks for your help!
The example broadcasts the closure only to demonstrate that you can manipulate with the queue from any node in the topology. You can have several clients that will write or read to/from the queue and the whole process will be globally synchronized. So yes, the first scenario is definitely possible.