Kafka
Sender Server
Mongodb
MqInfo
Register
Eureka
Consumer Server
Payload
Message
- messageId: String- thirdId: String(第三方消息ID)- topic: String- messageKey: String(消息业务key)- msgContent: String(原始消息内容)- path: String(消息当前路径)- status: Integer(0已发送，1成功，2异常，3私信)- retry: Integer(当前重发次数)- createTime: Date- updateTime: Date
ConsumerConnect
- id: Long- topic: String- gid: String- tag: String- mqId: Long(broker信息)- status: Integer(连接状态，0未连接，1已连接，2离线)- connectTime: Date- updateTime: Date- callbackUrl: String(回调地址，多个用逗号隔开)
Status
Wx Template Message
Rocket MQ
Api
MQ Broker
Message Init
Task
Message report
ConnectInfo
Statistics（日周月统计）
- id: Long- msgCount: Integer(消息总数)- unusualCount: Integer(异常消息总数)- deadCount: Integer(死信消息)- statisticsDate: Date
RabbitMQ
Sender
Broker
Message Manager&Monitor
Connecters
Pay Message
Other
TopicInfo
ProducerConnect
- id: Long- topic: String- gid: String- tag: String- mqId: Long(broker信息)- status: Integer(连接状态，0未连接，1已连接，2离线)- connectTime: Date- updateTime: Date
Statistics
Business Service
Topic
- id: Long- brokerId: Long(关联MQ的ID)- topic: String(unique)- gid: String- tag: String- createTime: Date- updateTime: Date
ActiveMQ
