Glific v0.3.1 Glific.Processor.ConsumerFlow View Source
Process all messages of type consumer and run them thru the various in-built taggers. At a later stage, we will also do translation and dialogflow queries as an offshoot from this GenStage
Link to this section Summary
Functions
Start a flow or reactivate a flow if needed. This will be linked to the entire trigger mechanism once we have that under control.
This callback handles the nudges in the system. It processes the jobs and then sets a timer to invoke itself when done
Link to this section Functions
Specs
check_flows(atom() | Glific.Messages.Message.t(), String.t(), map()) :: {map(), Glific.Messages.Message.t()}
Start a flow or reactivate a flow if needed. This will be linked to the entire trigger mechanism once we have that under control.
This callback handles the nudges in the system. It processes the jobs and then sets a timer to invoke itself when done