Skip to content

Commit dd26dbe

Browse files
committed
add stop
1 parent 3963fe3 commit dd26dbe

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

utils/Canary/src/main/java/canary/mqtt5/Mqtt5Canary.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -399,7 +399,7 @@ public void accept(Mqtt5WebsocketHandshakeTransformArgs t) {
399399

400400
public static void setupOperations() {
401401
// For now have everything evenly distributed
402-
// clientsOperationsList.add(CANARY_OPERATIONS.OPERATION_STOP);
402+
clientsOperationsList.add(CANARY_OPERATIONS.OPERATION_STOP);
403403
clientsOperationsList.add(CANARY_OPERATIONS.OPERATION_SUBSCRIBE);
404404
clientsOperationsList.add(CANARY_OPERATIONS.OPERATION_UNSUBSCRIBE);
405405
// clientsOperationsList.add(CANARY_OPERATIONS.OPERATION_UNSUBSCRIBE_BAD);

0 commit comments

Comments
 (0)