package com.adobe.tdf;
 
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
 
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import com.maxmind.geoip.Location;
import com.maxmind.geoip.LookupService;
 
import flex.messaging.MessageBroker;
import flex.messaging.messages.AsyncMessage;
import flex.messaging.util.UUIDUtils;
 
publicclass TDFServlet extends HttpServlet {
 
        // Unique clientID for the message service
        private String clientID = UUIDUtils.createUUID();
 
        // The geocoding service
        protected LookupService lookupService;
 
        // A DAO to store sample requests in a database
        protected SampleRequestDAO dao = new SampleRequestDAO();
 
        // The LCDS message broker
        protected MessageBroker messageBroker;
 
        // The LCDS messaging destination where real time sample requests information is pushed
        protected String destination; 
 
        publicvoid init() throws ServletException {
 
               ServletConfig config = getServletConfig();
               destination = config.getInitParameter("messaging.destination.name");
               String path = config.getInitParameter("geocoding.database.path");
               try {
                       // Load the geocoding database in init() to make sure we load it only once
                       lookupService = new LookupService(path, LookupService.GEOIP_MEMORY_CACHE);
               } catch (IOException e) {
                       // We swallow the exception here. If the database is not available, the feed
                       // will still work but won't provide the location info.
               }       
        }
 
        protectedvoid doGet(HttpServletRequest request, HttpServletResponse response)
                       throws ServletException, IOException {
 
               if (messageBroker == null)
               {
                       messageBroker = MessageBroker.getMessageBroker(null);
               }
 
               SampleRequest sampleRequest = new SampleRequest();
 
               try {
                       sampleRequest.setSampleId(Integer.parseInt(request.getParameter("sampleId")));
               } catch (Exception e) {
                       String message = "A valid sampleId is required to process this request";
                       thrownew RuntimeException(message);
               }
 
               sampleRequest.setTimestamp(new Date());
 
               String ipAddress = request.getParameter("ipAddress");
 
               // Geolocate the IP address and add the info to the message
               if (lookupService != null && ipAddress != null)
               {
                        Location location = lookupService.getLocation(ipAddress);
                       if (location != null)
                       {
                               sampleRequest.setLatitude(location.latitude);
                               sampleRequest.setLongitude(location.longitude);
                               sampleRequest.setCountry(location.countryCode);
                               sampleRequest.setCity(location.city);
                       }
               }
 
               try {
                       dao.create(sampleRequest, ipAddress);
               } catch (RuntimeException e) {
 
               }
 
               String subtopic = request.getParameter("subtopic");
               if (subtopic == null) subtopic = "flex";
 
               // Publish the message to specified destination and subtopic.
               AsyncMessage msg = new AsyncMessage();
               msg.setDestination(destination);
               msg.setHeader("DSSubtopic", subtopic);
               msg.setClientId(clientID);
               msg.setMessageId(UUIDUtils.createUUID());
               msg.setTimestamp(System.currentTimeMillis());
               msg.setBody(sampleRequest);
               messageBroker.routeMessageToService(msg, null);
 
               PrintWriter out = response.getWriter();
                out.println("<html><body>ok</body></html>");
 
        }
 
}

<mx:ChannelSet id="channelSet"><mx:RTMPChannel id="rtmp" url="rtmp://hostname:2037"/>
        <mx:AMFChannel url="http://hostname/context/messagebroker/amflongpolling"/>
        <mx:AMFChannel url="http://hostname/context/messagebroker/amfpolling"/>
</mx:ChannelSet>