🚀 go-pugleaf

William Yu wrote:
> 
> I can think of one detection hack -- if the corresponding
> dataItemRequested() in the producer does not execute, that means target
> consumer never answered. With this, I could set up a flag, launch a
> thread to wait 5 seconds and so on.
> 
> But obviously, I'd like to implement a more elegant method. Is there
> something in the API I'm missing? Has anyone else had to deal with this
> issue?


Answering my own question here.

From looking through the Infobus API, I find I can use the
DataController interface to detect members joining and leaving an
Infobus. Unfortunately, it's not one simple API call. You have to
implement a class to maintain the bookkeeping yourself --
straightforward for the purpose of detecting members, somewhat more
complicated if you want to implement "controller" functionality and what
not for performance reasons. (By default, all DataConsumers are
activated when a Producer calls InfoBus' fireItemAvailable() and all
DataProducers are activated when a Consumer calles InfoBus'
findItemAvailable() -- a DataController can act like a matchmaking so
only the needed producers & consumers are involved.)