Merge pull request #4996 from donald-jackson/kraken/int-stream-fix

[kraken] fix check to allow integers
knowm · Jan 30, 2025 · 1f1edcc · 1f1edcc
2 parents 1b1089f + e971c5c
commit 1f1edcc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...stream-kraken/src/main/java/info/bitrich/xchangestream/kraken/KrakenStreamingService.java b/...stream-kraken/src/main/java/info/bitrich/xchangestream/kraken/KrakenStreamingService.java
@@ -238,7 +238,7 @@ protected String getChannelNameFromMessage(JsonNode message) throws IOException
     }
 
     if (message.isArray()) {
-      if (message.get(0).isLong()) {
+      if (message.get(0).isInt() || message.get(0).isLong()) {
         LOG.trace("Taking channelName from ID from first field LONG).");
         long channelId = message.get(0).asLong();
         return channels.getOrDefault(channelId, String.valueOf(channelId));