package nb.iptv;

import flex.messaging.messages.Message;=20
import flex.messaging.services.MessageService;=20
import flex.messaging.services.ServiceAdapter;=20

/** * Custom Service Adapter which does the following * *=20
 	* 1) Generating an initial set of random numbers.=20
 	* 2) Process the incoming messages.=20
 	* 3) Responsible for pushing the message to all the clients.=20
 	* 4) Responsible for sending the current state as part of ack.=20
 	* * @author Siva Prasanna Kumar .P */=20

public class DataHandler extends ServiceAdapter{ =20
=09
	@Override
    public Object invoke(Message message) {
    	=
System.out.println("::::::::::::::::Aaaaaaaaa::::::::::::::::"+message.ge=
tBody());
        MessageService msgService =3D =
(MessageService)getDestination().getService();
        msgService.pushMessageToClients(message, true);
       // msgService.sendPushMessageFromPeer(message, true);
        return null;
    }
}