[core] Not all messages are in a channel

we see confirms an errors without a channel designation. @makarid I believe you were asking about this
mdvx · Mar 6, 2020 · 5d99819 · 5d99819 · makarid · Mar 6, 2020
1 parent 0c5fa85
commit 5d99819
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...e-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java b/...e-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
@@ -408,12 +408,14 @@ protected String getChannel(T message) {
 
   protected void handleMessage(T message) {
     String channel = getChannel(message);
-    handleChannelMessage(channel, message);
+    if (channel != null)
+      handleChannelMessage(channel, message);
   }
 
   protected void handleError(T message, Throwable t) {
     String channel = getChannel(message);
-    handleChannelError(channel, t);
+    if (channel != null)
+      handleChannelError(channel, t);
   }
 
   protected void handleIdle(ChannelHandlerContext ctx) {