dev

src/main/java/com/its/op/scheduler/job/FcltSttsJobThread.java

@@ -53,7 +53,7 @@ public class FcltSttsJobThread {
         stopWatch.stop();
         long totalTimeMillis = stopWatch.getTotalTimeMillis();
         if (totalTimeMillis > 2000) {
-            log.info("--END: FcltSttsJobThread.run: {}, {} ms.", Thread.currentThread().getName(), stopWatch.getTotalTimeMillis());
+            log.info("FcltSttsJobThread.run:--END. {}, {} ms.", Thread.currentThread().getName(), stopWatch.getTotalTimeMillis());
         }
     }
 }

src/main/java/com/its/op/xnetudp/codec/CenterCommServerDecoder.java

@@ -18,7 +18,7 @@ public class CenterCommServerDecoder extends MessageToMessageDecoder<DatagramPac
 		ByteBuf buf = packet.content();
 
 		int recvBytes = buf.readableBytes();
-		log.info("RECV UDP: [{}], {} Bytes.", packet.sender().getAddress().getHostAddress(), recvBytes);
+		//log.info("RECV UDP: [{}], {} Bytes.", packet.sender().getAddress().getHostAddress(), recvBytes);
 
 		if (buf.readableBytes() < CENTER_COMM_MESSAGE.CENTER_HEADER_SIZE) {
 			log.error("RECV UDP: UDP Message header length error: {}/{} Bytes.", recvBytes, CENTER_COMM_MESSAGE.CENTER_HEADER_SIZE);

src/main/java/com/its/op/xnetudp/thread/CenterCommServerReceiver.java

@@ -35,7 +35,7 @@ public class CenterCommServerReceiver {
             return;
         }
 
-//        log.error("CenterCommServerReceiver: {}::{}::{}", data.getSendId(), data.getOpCode(), data.getSenderIp());
+        log.info("CenterCommServerReceiver: {}::{}::{}", data.getSendId(), data.getOpCode(), data.getSenderIp());
         if (CENTER_COMM_DEFINE.INT_ID_TRAFFIC_SERVER == data.getSendId()) {
             if (CENTER_COMM_DEFINE.INT_OP_TRAFFIC_CHANGE == data.getOpCode()) {
                 String prcsTm = ItsUtils.getCurrFiveMinString();
@@ -200,6 +200,7 @@ public class CenterCommServerReceiver {
                         break;
                 }
             }
+            return;
         }
 
         String reqIpAddr = data.getSenderIp();