properly handled InterruptedException

Signed-off-by: Kalin Kostashki <[email protected]>

Author: kalinkostashki

java/src/main/java/org/eclipse/ditto/client/messaging/internal/WebSocketMessagingProvider.java

@@ -372,10 +372,15 @@ public void onConnected(final WebSocket websocket, final Map<String, List<String
                         LOGGER.debug("Reconnecting is completed -> emitting subscriptionMessages: {}", subscriptionMessages);
                         subscriptionMessages.values().forEach(this::emit);
                     }
-                } catch (TimeoutException | InterruptedException | ExecutionException e) {
+                } catch (TimeoutException | ExecutionException e) {
                     isReconnecting.complete(false);
                     fixedRateChecker.cancel(true);
                     LOGGER.error("Reconnecting failed: {}", e.getMessage());
+                } catch (InterruptedException e) {
+                    isReconnecting.complete(false);
+                    fixedRateChecker.cancel(true);
+                    LOGGER.error("Reconnecting failed due to thread being interrupted: {}", e.getMessage());
+                    Thread.currentThread().interrupt();
                 }
             }
         });