PitayaMQ
2023-09-21 16:36:56 0 举报
登录查看完整内容
为你推荐
查看更多
抱歉,暂无相关内容
消息流程
作者其他创作
大纲/内容
new WebSocketServer(\"producer\
writer
LocalConsumerTransferManager
PitayaProducer
ProducerWebSocketHandler
CassandraMetricService
ConsumerTransfer
transfer() { notify(localQueue.pollAll()) }
MqConfig
new WebSocketServer(\"consumer\
LocalQueue localQueue
LocalConsumerTransfer
0 条评论
回复 删除
下一页