后台主动推数据

后台主动推数据
view sourceprint?1 AsyncMessage msg = new AsyncMessage(); 

2                 msg.setDestination("tick-data-feed"); 

3                 msg.setHeader("DSSubtopic", "tick" + username); 

4                 msg.setClientId(clientID); 

5                 msg.setMessageId(UUIDUtils.createUUID()); 

6                 msg.setTimestamp(System.currentTimeMillis()); 

7                 StockVo vo = stockService.buildStockVo(stockService.genericWaveStock(node), user); 

8                 msg.setBody(vo); 

9                 msgBroker.routeMessageToService(msg, null);


前台代码：



view sourceprint?
01 var myStreamingAMF:StreamingAMFChannel = new StreamingAMFChannel("my-streaming-amf", "http://localhost/cfowebgame/messagebroker/streamingamf"); 

02                  

03                //访问后台，调用股票曲线 

04                remoteObject.getStockCurve(); 

05                var consumer:Consumer = new Consumer(); 

06                consumer.destination = "tick-data-feed"; 

07                consumer.subtopic = "tick"+username; 

08                  

09               var channelSet:ChannelSet = new ChannelSet(); 

10                channelSet.addChannel(myStreamingAMF); 

11          

12                consumer.channelSet = channelSet;                

13                  

14                consumer.addEventListener(MessageEvent.MESSAGE, messageHandler); 

15                consumer.subscribe();//主动订阅后台数据
这儿主要使用StreamingAMFChannel.

后台可以主动推给前台数据。