diff --git a/src/main/java/com/github/jnidzwetzki/bitfinex/v2/callback/channel/ExecutedTradeHandler.java b/src/main/java/com/github/jnidzwetzki/bitfinex/v2/callback/channel/ExecutedTradeHandler.java index 2d93216..cd5e0d5 100644 --- a/src/main/java/com/github/jnidzwetzki/bitfinex/v2/callback/channel/ExecutedTradeHandler.java +++ b/src/main/java/com/github/jnidzwetzki/bitfinex/v2/callback/channel/ExecutedTradeHandler.java @@ -21,6 +21,7 @@ import java.util.ArrayList; import java.util.Collection; import java.util.List; +import java.util.Objects; import java.util.function.BiConsumer; import org.json.JSONArray; @@ -51,7 +52,7 @@ public void handleChannelData(final String action, final JSONArray jsonArray) th try { final List trades = new ArrayList<>(); - if( action.equals("tu")) { + if(Objects.nonNull(action) && action.equals("tu")) { return; // Ignore tu messages (see issue #13) }