基于Java实现的。Timeline模式朋友圈、微博、消息推送、feed流、im通讯的抽象库，提供数据流间的分发功能、分发失败后重试，将抽象层、存储层分离提高系统灵活性、以及各种存储层的具体实现。
它的本质是一款消息队列，但是消息队列又过于抽象，因此我们将具体的某些业务进行抽离、加工、设计，转换为一类以消息队列为核心的业务实现方法。
不稳定、开发分支
dev-v2
吸取版本1的经验与不足，对整个框架进行重构，目标是使逻辑更加简便快捷
目前整个设计、代码实现还在规划，预计相对完善的可用的版本是V2.1
- 轻量级MQ，小到仅需要去下jar包便可以使用。或轻量级服务间消息队列通讯(无中间件、点对点通讯)。
- 专有化的消息队列。旨在解决某类特有消息队列模型下的业务流处理方法。
在仓库A中用户1的信息实时的同步到仓库B、C...中。当用户1的信息在A仓中被修改、删除时也会实时同步。 数据流程如下：
-
仓A新建用户1，数据同步至仓B，数据同步至仓C...
-
仓A修改用户1，数据同步至仓B，数据同步至仓C...
-
仓A删除用户1，数据同步至仓B，数据同步至仓C...
-
仓A创建用户2，数据同步至仓B，数据同步至仓C...
上述数据流微观描述：仓A作为数据生成者。仓B、仓C...作为数据消费者。
- 数据单向流动
- 数据存在顺序性
- 生产者和消费者的数据被消息代理持久化，解耦生产或消费时的高可用处理逻辑。
- 生产者和消费者关系解耦，实时的增删生产者与消费者关系