fix

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -83,9 +83,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                 String[] split = message.split("&&");
                 if (split.length == 3) {
                     JSONObject jsonObject = HJ212MsgUtils.dealMsg2(message);
-                    if (jsonObject!=null && jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
-                            || jsonObject.getString(Constant.CN).equals(Constant.HOUR)
-                            || jsonObject.getString(Constant.CN).equals(Constant.REAL)){
+                    if ((jsonObject!=null && jsonObject.getString(Constant.CN).equals(Constant.MINUTE))
+                            ||(jsonObject!=null && jsonObject.getString(Constant.CN).equals(Constant.HOUR))){
                         adapter.publisherService.pubMsg(jsonObject);
 //                        adapter.redisQueueService.sendMessage(Constant.SERVER, jsonObject);
                     }
@@ -94,9 +93,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                         String startStr = dataMap.get(ctx.channel().id().toString());
                         startStr = startStr + message;
                         JSONObject jsonObject = HJ212MsgUtils.dealMsg2(startStr);
-                        if (jsonObject!=null &&  jsonObject.getString(Constant.CN).equals(Constant.MINUTE)
-                                || jsonObject.getString(Constant.CN).equals(Constant.HOUR)
-                                || jsonObject.getString(Constant.CN).equals(Constant.REAL)){
+                        if ((jsonObject!=null &&  jsonObject.getString(Constant.CN).equals(Constant.MINUTE))
+                                || (jsonObject!=null && jsonObject.getString(Constant.CN).equals(Constant.HOUR))){
 //                            adapter.redisQueueService.sendMessage(Constant.SERVER, jsonObject);
                             adapter.publisherService.pubMsg(jsonObject);
                         }
@@ -114,6 +112,7 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
             }
         } catch (Exception e) {
             System.out.println("channelRead--" + e.toString());
+            throw  new RuntimeException(e);
         }
     }
     /**