a simple liteflow demo

流程

场景：
感知 -> 条件判断 -> 决策

感知为输入，目前支持了kafka和mqtt；
决策为输出，支持kafka，mqtt，console;
条件判断控制输出是否满足一定的条件，如果满足则执行决策，否则跳过。

source和sink模块为自定义实现类，transformer采用liteflow规则引擎实现.

数据流转

以eventbus为中转，
source数据进入eventbus，
transformer订阅数据，并根据规则进行数据转换，结果写入消息总线
sink订阅消息总线，并输出数据。
具体实现见 com/liteflow/test/executor

source和sink扩展

source和sink分别实现SourceCmp和SinkCmp接口
并将消息写入或订阅消费eventbus