Skip to content

Commit accd54b

Browse files
committed
fix compile
1 parent aebe279 commit accd54b

1 file changed

Lines changed: 5 additions & 7 deletions

File tree

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

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -525,13 +525,11 @@ public static void OperationUnsubscribe(int clientIdx) {
525525
UnsubscribePacketBuilder unsubscribePacketBuilder = new UnsubscribePacketBuilder();
526526
unsubscribePacketBuilder.withSubscription(clientsData.get(clientIdx).clientId);
527527
unsubscribePacketBuilder.withSubscription(clientsData.get(clientIdx).sharedTopic);
528-
try {
529-
client.unsubscribe(unsubscribePacketBuilder.build());
530-
// PrintLog("[OP] Unsubscribe had an exception! Exception: " + ex);
531-
ex.printStackTrace();
532-
if (configFilePrinter != null) {
533-
ex.printStackTrace(configFilePrinter);
534-
}
528+
client.unsubscribe(unsubscribePacketBuilder.build());
529+
// PrintLog("[OP] Unsubscribe had an exception! Exception: " + ex);
530+
ex.printStackTrace();
531+
if (configFilePrinter != null) {
532+
ex.printStackTrace(configFilePrinter);
535533
}
536534
clientsData.get(clientIdx).subscribedToTopics = false;
537535
// PrintLog("[OP] Unsubscribed client ID " + clientIdx);

0 commit comments

Comments
 (0)