MessageDeadService
+ messageDeadDao
- boolean add()
MessageDeadDao
- int insert()- delete()- List list()- int count()
SendException
MessagePool
+ rocketMQConfig- falconMetricService+ messageDeadService- producer
- init()- routing()- retry()- destroy()
AbstractSendGateWay
- falconMetricService- logger
- init()- execute()- abstract String getMethod()- abstract boolean before()- abstract void after()- abstract void doExecute()
MessageHandler
+ rocketMQConfig+ messageHandlerListener- consumer
- init()- destroy()
MessageHandlerListener
+ messagePool+ httpSendGateWay- falconMetricService
- ConsumeConcurrentlyStatus consumeMessage()
RocketMQConfig
- groupName- namesrvAddr- sharedTopic- retryTopic
HttpSendGateWay
+ appInfoDao
- String getMethod()- boolean before()- void after()- void doExecute()
MessageContext
- method- id- appId- timestamp- session- retry- data- bizId- from- uid- appId
