自定义Messaging Service Adapter发送消息到订阅客户端

原文：http://fykyx521.iteye.com/blog/384020

 

package adapter;

import flex.messaging.io.amf.ASObject;
import flex.messaging.messages.Message;
import flex.messaging.services.MessageService;
import flex.messaging.services.messaging.adapters.ActionScriptAdapter;

public class MyAdapter extends ActionScriptAdapter {

    public MyAdapter()
    {
        super();
    }

    public Object invoke(Message message)
    {
    	if(message instanceof CommandMessage){
    		CommandMessage cm=(CommandMessage)message;   		
    	}
        MessageService msgService = (MessageService)getDestination().getService();
    
        msgService.pushMessageToClients(message, true);//发送消息 
        // 集群发送消息
        msgService.sendPushMessageFromPeer(message, true);
      
        // 得到消息体
        Object obj=message.getBody();
	    ASObject as = (ASObject)obj;
        // 添加或者修改消息体内容
	    as.put("title", "LCDS");	
        return null;
    }
}