noflo / noflo-runtime-msgflo

NoFlo runtime for AMQP/MQTT
10 stars 8 forks source link

Communicate all FBP runtime messages to coordinator #30

Open jonnor opened 8 years ago

jonnor commented 8 years ago

We now have a queue/exchange pair (sending, receiving) for communicating FBP protocol messages, from a single participant to coordinator. But currently only trace commands are handled. Instead all FBP runtime messages should be forwarded. This requires loading the graph with runtime.MsgFloRuntime instead of using noflo.ComponentLoader like we do now.

Needed to allow full nested access to NoFlo runtimes running inside/behind a MsgFlo runtime.

The queue names used for this purpose should be put in the MsgFlo participant discovery messages.

jonnor commented 8 years ago

There are a couple of things needed here: