public class org.apache.activemq.web.PortfolioPublishServlet extends org.apache.activemq.web.MessageServletSupport { private static final int MAX_DELTA_PERCENT; private static final java.util.Map LAST_PRICES; public void () { org.apache.activemq.web.PortfolioPublishServlet v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; specialinvoke v.()>(); return; } public void init() throws javax.servlet.ServletException { org.apache.activemq.web.PortfolioPublishServlet v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; specialinvoke v.(); return; } protected void doGet(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) throws javax.servlet.ServletException, java.io.IOException { java.lang.Throwable v; java.lang.String[] v; java.lang.Integer v; javax.servlet.http.HttpServletRequest v; int v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.io.PrintWriter v; javax.servlet.http.HttpSession v, v; org.apache.activemq.web.PortfolioPublishServlet v; javax.servlet.http.HttpServletResponse v; org.apache.activemq.web.WebClient v; java.lang.Object v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: javax.servlet.http.HttpServletResponse; v = interfaceinvoke v.(); v = interfaceinvoke v.("stocks"); if v == null goto label; v = lengthof v; if v != 0 goto label; label: virtualinvoke v.("No stocks query parameter specified. Cannot publish market data"); goto label; label: v = interfaceinvoke v.(1); v = interfaceinvoke v.("total"); if v != null goto label; v = staticinvoke (0); label: v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v + v; v = staticinvoke (v); v = interfaceinvoke v.(); interfaceinvoke v.("total", v); label: v = staticinvoke (v); v = 0; label: if v >= v goto label; virtualinvoke v.(v, v); v = v + 1; goto label; label: virtualinvoke v.("("refresh"); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = "1"; label: v = virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.("\'/>"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Published \u0001 of \u price messages. Refresh = \u0001s"); virtualinvoke v.(v); virtualinvoke v.(""); label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed sending price messages due to \u0001"); virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to send message: \u0001"); virtualinvoke v.(v, v); label: return; catch javax.jms.JMSException from label to label with label; } protected void sendMessage(org.apache.activemq.web.WebClient, java.lang.String[]) throws javax.jms.JMSException { org.apache.activemq.web.PortfolioPublishServlet v; javax.jms.TextMessage v; java.lang.String[] v; javax.jms.Topic v; long v; javax.jms.Session v; org.apache.activemq.web.WebClient v; int v, v; java.lang.String v, v, v, v; double v, v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: org.apache.activemq.web.WebClient; v := @parameter: java.lang.String[]; v = virtualinvoke v.(); label: v = lengthof v; v = staticinvoke (); v = v * v; v = staticinvoke (v); v = lengthof v; if v >= v goto label; v = v[v]; v = dynamicinvoke "makeConcatWithConstants" (v) ("STOCKS.\u0001"); v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Sending: \u on destination: \u0001"); virtualinvoke v.(v); v = interfaceinvoke v.(v); virtualinvoke v.(v, v); return; } protected java.lang.String createStockText(java.lang.String) { java.lang.Double v, v; byte v; java.util.Map v, v; java.lang.String v, v, v; double v, v, v, v, v, v; org.apache.activemq.web.PortfolioPublishServlet v; java.lang.Object v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: java.lang.String; v = ; v = interfaceinvoke v.(v); if v != null goto label; v = new java.lang.Double; v = staticinvoke (); v = v * 100.0; specialinvoke v.(double)>(v); v = v; label: v = virtualinvoke v.(); v = new java.lang.Double; v = virtualinvoke v.(v); specialinvoke v.(double)>(v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = v * 1.001; v = v cmpl v; if v <= 0 goto label; v = "up"; goto label; label: v = "down"; label: v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) (""); return v; } protected double mutatePrice(double) { org.apache.activemq.web.PortfolioPublishServlet v; double v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: double; v = staticinvoke (); v = 2.0 * v; v = v * 1.0; v = v - 1.0; v = 100.0 + v; v = v * v; v = v / 100.0; return v; } protected int getNumberOfMessages(javax.servlet.http.HttpServletRequest) { javax.servlet.http.HttpServletRequest v; org.apache.activemq.web.PortfolioPublishServlet v; int v; java.lang.String v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: javax.servlet.http.HttpServletRequest; v = interfaceinvoke v.("count"); if v == null goto label; v = staticinvoke (v); return v; label: return 1; } protected java.lang.String escape(java.lang.String) throws java.io.IOException { java.lang.String v, v; org.apache.activemq.web.PortfolioPublishServlet v; v := @this: org.apache.activemq.web.PortfolioPublishServlet; v := @parameter: java.lang.String; v = staticinvoke (v, "UTF-8"); return v; } static void () { java.util.Hashtable v; v = new java.util.Hashtable; specialinvoke v.()>(); = v; return; } }