[kraken] fix check to allow integers

donald-jackson · donald-jackson · commit e971c5c43b54 · 2025-01-29T22:42:48.000+01:00
diff --git a/xchange-stream-kraken/src/main/java/info/bitrich/xchangestream/kraken/KrakenStreamingService.java b/xchange-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));

Original file line number	Diff line number	Diff line change
`@@ -238,7 +238,7 @@ protected String getChannelNameFromMessage(JsonNode message) throws IOException`
`238`	`238`	`}`
`239`	`239`
`240`	`240`	`if (message.isArray()) {`
`241`		`- if (message.get(0).isLong()) {`
	`241`	`+ if (message.get(0).isInt() \|\| message.get(0).isLong()) {`
`242`	`242`	`LOG.trace("Taking channelName from ID from first field LONG).");`
`243`	`243`	`long channelId = message.get(0).asLong();`
`244`	`244`	`return channels.getOrDefault(channelId, String.valueOf(channelId));`