add the handler

cat-broker/src/main/java/com/dianping/cat/broker/api/page/batch/Handler.java

@@ -15,6 +15,7 @@ import org.unidal.web.mvc.annotation.InboundActionMeta;
 import org.unidal.web.mvc.annotation.OutboundActionMeta;
 import org.unidal.web.mvc.annotation.PayloadMeta;
 
+import com.dianping.cat.Cat;
 import com.dianping.cat.broker.api.app.AppData;
 import com.dianping.cat.broker.api.app.AppDataConsumer;
 import com.dianping.cat.broker.api.page.Constrants;
@@ -24,6 +25,7 @@ import com.dianping.cat.broker.api.page.MonitorEntity;
 import com.dianping.cat.broker.api.page.MonitorManager;
 import com.dianping.cat.broker.api.page.RequestUtils;
 import com.dianping.cat.config.app.AppConfigManager;
+import com.dianping.cat.message.Event;
 
 public class Handler implements PageHandler<Context>, LogEnabled {
 
@@ -64,18 +66,27 @@ public class Handler implements PageHandler<Context>, LogEnabled {
 		HttpServletResponse response = ctx.getHttpServletResponse();
 		String userIp = m_util.getRemoteIp(request);
 		String version = payload.getVersion();
-
+		boolean success = true;
+		
 		if (userIp != null) {
 			if ("1".equals(version)) {
 				processVersion1(payload, request, userIp);
 			} else if ("2".equals(version)) {
 				processVersion2(payload, request, userIp);
+			} else {
+				success=false;
+				Cat.logEvent("InvalidVersion", version, Event.SUCCESS, version);
 			}
 		} else {
+			success = false;
 			m_logger.info("unknown http request, x-forwarded-for:" + request.getHeader("x-forwarded-for"));
 		}
 
-		response.getWriter().write("OK");
+		if (success){
+			response.getWriter().write("OK");			
+		}else{
+			response.getWriter().write("validate request!");
+		}
 	}
 
 	private void processVersion1(Payload payload, HttpServletRequest request, String userIp) {
@@ -161,10 +172,15 @@ public class Handler implements PageHandler<Context>, LogEnabled {
 					appData.setCount(1);
 
 					m_appDataConsumer.enqueue(appData);
+					Cat.logEvent("Command", String.valueOf(command), Event.SUCCESS, null);
+				} else {
+					Cat.logEvent("Command", items[1], Event.SUCCESS, items[1]);
 				}
 			} catch (Exception e) {
 				m_logger.error(e.getMessage(), e);
 			}
+		} else {
+			Cat.logEvent("InvalidPar", items[1], Event.SUCCESS, items[1]);
 		}
 	}