@@ -0,0 +1,541 @@
+package com.doctor.esper.common;%0A%0Aimport org.slf4j.Logger;%0Aimport org.slf4j.LoggerFactory;%0A%0Aimport com.espertech.esper.client.EventBean;%0A%0Apublic final class MyUpdateListener %7B%0A%09private static final Logger log = LoggerFactory.getLogger(MyUpdateListener.class);%0A%0A%09public static void update(EventBean%5B%5D newEvents, EventBean%5B%5D oldEvents) %7B%0A%09%09if (newEvents != null && newEvents%5B0%5D != null) %7B%0A%09%09%09log.info(%22%7BnewEvents:%7B%7D%7D%22, newEvents%5B0%5D);%0A%09%09%7D%0A%09%09if (oldEvents != null && oldEvents%5B0%5D != null) %7B%0A%09%09%09log.info(%22%7BoldEvents:%7B%7D%7D%22, oldEvents%5B0%5D);%0A%09%09%7D%0A%09%7D%0A%7D%0A

add common UpdateListener