import flex.messaging.MessageBroker; import flex.messaging.MessageDestination; import flex.messaging.Message; public class DataPushService { private static MessageBroker messageBroker; public static void main(String[] args) { messageBroker = MessageBroker.getMessageBroker(null); messageBroker.setClusterId("my-cluster"); MessageDestination destination = new MessageDestination(); destination.setId("dataDestination"); destination.setClassName("flex.messaging.services.HTTPProxy"); destination.addForwardHeaders("*"); messageBroker.addDestination(destination); messageBroker.start(); } public static void pushData(Object data) { Message message = new Message(); message.setDestination("dataDestination"); message.setBody(data); messageBroker.routeMessageToService(message, null); } }