FairMQ/examples/MQ/6-multiple-channels
Florian Uhlig 54ff30f055 Fix compiler warnings.
Initialize all data members in initializer lists.
Reorder data members in initializer list to have the same order as in the class declaration.
Comment or remove unused parameters and unused variables.
Convert all old style casts to the correct and explicit c++ cast like const_cast, static_cast,
dynamic_cast or reinterpret_cast. In most cases static_cast is used.
2018-05-02 13:51:55 +02:00
..
CMakeLists.txt Add FlatBuffers & MessagePack examples 2018-05-02 13:51:55 +02:00
ex6-multiple-channels.json FairMQ: Extend Multipart and messaging API 2018-05-02 13:51:55 +02:00
FairMQExample6Broadcaster.cxx Fix compiler warnings. 2018-05-02 13:51:55 +02:00
FairMQExample6Broadcaster.h Rename /example to /examples and move MQ examples in it 2018-05-02 13:51:55 +02:00
FairMQExample6Sampler.cxx Fix compiler warnings. 2018-05-02 13:51:55 +02:00
FairMQExample6Sampler.h Rename /example to /examples and move MQ examples in it 2018-05-02 13:51:55 +02:00
FairMQExample6Sink.cxx FairMQ: Extend Multipart and messaging API 2018-05-02 13:51:55 +02:00
FairMQExample6Sink.h Rename /example to /examples and move MQ examples in it 2018-05-02 13:51:55 +02:00
README.md Rename /example to /examples and move MQ examples in it 2018-05-02 13:51:55 +02:00
runExample6Broadcaster.cxx Remove compile time transport interface switch 2018-05-02 13:51:55 +02:00
runExample6Sampler.cxx Remove compile time transport interface switch 2018-05-02 13:51:55 +02:00
runExample6Sink.cxx Remove compile time transport interface switch 2018-05-02 13:51:55 +02:00

Example 6: Multiple Channels

This example demonstrates how to work with multiple channels and multiplex between them.

A topology of three devices - Sampler, Sink and Broadcaster. The Sampler sends data to the Sink via the PUSH-PULL pattern. The Broadcaster device sends a message to both Sampler and Sink containing a string "OK" every second. The Broadcaster sends the message via PUB pattern. Both Sampler and Sink, besides doing their PUSH-PULL job, listen via SUB to the Broadcaster.

The multiplexing between their data channels and the broadcast channels happens with FairMQPoller.