Configure ignoring of unsubscribe exceptions

Author: KirillSmirnow

crypto-messenger-coder/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.example</groupId>
         <artifactId>crypto-messenger</artifactId>
-        <version>1.1.1</version>
+        <version>1.1.2</version>
     </parent>
 
     <artifactId>crypto-messenger-coder</artifactId>

crypto-messenger-desktop/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.example</groupId>
         <artifactId>crypto-messenger</artifactId>
-        <version>1.1.1</version>
+        <version>1.1.2</version>
     </parent>
 
     <artifactId>crypto-messenger-desktop</artifactId>

crypto-messenger-desktop/src/main/java/cryptomessenger/desktop/infrastructure/client/websocket/WebSocketManager.java

@@ -54,13 +54,20 @@ private void connect() {
     }
 
     public void refreshSubscriptions() {
-        subscriptions.forEach(Subscription::unsubscribe);
+        subscriptions.forEach(this::unsubscribe);
         subscriptions = messageHandlers.stream()
                 .map(this::subscribe)
                 .flatMap(Optional::stream)
                 .collect(toSet());
     }
 
+    private void unsubscribe(Subscription subscription) {
+        try {
+            subscription.unsubscribe();
+        } catch (Exception e) {
+        }
+    }
+
     private Optional<Subscription> subscribe(MessageHandler handler) {
         var handlerName = handler.getClass().getSimpleName();
         try {

crypto-messenger-server/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.example</groupId>
         <artifactId>crypto-messenger</artifactId>
-        <version>1.1.1</version>
+        <version>1.1.2</version>
     </parent>
 
     <artifactId>crypto-messenger-server</artifactId>

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>org.example</groupId>
     <artifactId>crypto-messenger</artifactId>
-    <version>1.1.1</version>
+    <version>1.1.2</version>
     <packaging>pom</packaging>
 
     <modules>