From 5d998197ccda6a6cff2e9cb74d2efd1dda92b9d4 Mon Sep 17 00:00:00 2001
From: Marc Deveaux <mdvx@users.noreply.github.com>
Date: Thu, 5 Mar 2020 22:03:44 -0500
Subject: [PATCH] [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
---
 .../xchangestream/service/netty/NettyStreamingService.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java b/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
index e6d80fd59..9f328567d 100644
--- a/xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
+++ b/xchange-stream-service-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) {