EMS-JMS
2018-03-06 15:36:05 1 举报
登录查看完整内容
基于Solace的JMS业务设计，用于消息中心自动处理任务
作者其他创作
大纲/内容
Queue : FB_eventLevel_eventId
Queue : FB_001_255
DataQueue - Receiver : FB_001_255
4：发送消息到DataQueue
3：创建DataQueue
GameEventMessageReceiverManager
- JmsMessageConsumer messageConsumer
+ init( )+ addDestination(String destinationName)
QueueID : FB_001_255
6：接收消息
SolMessageConsumer
- MessageListener messageListener
Solace-JMS Server
GameEventMessageReceiver
+ onMessage(Message message)
eventLevel : 001eventId : 255messageContent : helloworld
Queue : test/sz/devin/que
controller 消息处理：helloworld
管道线程：FB_001_254：Thread1 - executeMessage( )
管道线程：FB_001_255：Thread1 - executeMessage( )
2：接收SPS消息
Receiver : test/sz/devin/que
服务器上动态创建QueueQueueName：FB_001_255
call addDestination( )
MessageReceiver
QueueName : FB_1_1
eventLevel : xxxeventId : xxxmessageContent : xxx
DataQueue - Receiver : FB_eventLevel_eventId
Queue : test/football
7：创建Receiver
ControlQueue - Receiver : FB_control
2：接收SPS-Message
3：线程池处理Message
Worker Thread
GameEventMessageReceiverManagerWork
- List receiverList
+ run()+ addReceiver(GameEventMessageReceiver)
ExecutorService
8：接收消息，from 5th step
5：发送消息到ControlQueue
QueueName : FB_CONTROLSampleData:{ QueueId : FB_1_1 }
1：SPS消息
1：SPS-Message
call addReceiver( )
管道线程：FB_001_253：Thread1 - executeMessage( )
Queue : FB_control
JmsMessageConsumer
职业：软件测试开发工程师
0 条评论
回复 删除
下一页
