Showing
1 changed file
with
1 additions
and
1 deletions
@@ -652,7 +652,7 @@ public class DefaultTelemetryWebSocketService implements TelemetryWebSocketServi | @@ -652,7 +652,7 @@ public class DefaultTelemetryWebSocketService implements TelemetryWebSocketServi | ||
652 | "Cmd id is negative value!"); | 652 | "Cmd id is negative value!"); |
653 | sendWsMsg(sessionRef, update); | 653 | sendWsMsg(sessionRef, update); |
654 | return false; | 654 | return false; |
655 | - } else if (cmd.getQuery() == null) { | 655 | + } else if (cmd.getQuery() == null && cmd.getLatestCmd() == null && cmd.getHistoryCmd() == null && cmd.getTsCmd() == null) { |
656 | SubscriptionUpdate update = new SubscriptionUpdate(cmd.getCmdId(), SubscriptionErrorCode.BAD_REQUEST, | 656 | SubscriptionUpdate update = new SubscriptionUpdate(cmd.getCmdId(), SubscriptionErrorCode.BAD_REQUEST, |
657 | "Query is empty!"); | 657 | "Query is empty!"); |
658 | sendWsMsg(sessionRef, update); | 658 | sendWsMsg(sessionRef, update); |