eclipse-leshan#933: Add method: onUnexpectedErrorOccurred() for LwM…

…2mClientObserver Add an interface method `void onUnexpectedErrorOccurred(Throwable unexpectedError)` into LwM2mClientObserver. This aims to hook a procedure when an unexpected error has been occurred. Signed-off-by: moznion <[email protected]>
moznion · Nov 30, 2020 · 2e3a324 · 2e3a324
1 parent a275f2b
commit 2e3a324
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 0 deletions.
diff --git a/leshan-client-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserver.java b/leshan-client-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserver.java
@@ -69,4 +69,8 @@ void onDeregistrationFailure(ServerIdentity server, DeregisterRequest request, R
             String errorMessage, Exception cause);
 
     void onDeregistrationTimeout(ServerIdentity server, DeregisterRequest request);
+
+    // ============== Unexpected Error Handling =================
+
+    void onUnexpectedErrorOccurred(Throwable unexpectedError);
 }
diff --git a/...ent-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserverAdapter.java b/...ent-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserverAdapter.java
@@ -95,4 +95,8 @@ public void onDeregistrationFailure(ServerIdentity server, DeregisterRequest req
     @Override
     public void onDeregistrationTimeout(ServerIdentity server, DeregisterRequest request) {
     }
+
+    @Override
+    public void onUnexpectedErrorOccurred(Throwable unexpectedError) {
+    }
 }
diff --git a/...-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserverDispatcher.java b/...-core/src/main/java/org/eclipse/leshan/client/observer/LwM2mClientObserverDispatcher.java
@@ -151,4 +151,10 @@ public void onDeregistrationTimeout(ServerIdentity server, DeregisterRequest req
         }
     }
 
+    @Override
+    public void onUnexpectedErrorOccurred(Throwable unexpectedError) {
+        for (LwM2mClientObserver observer : observers) {
+            observer.onUnexpectedErrorOccurred(unexpectedError);
+        }
+    }
 }