[camel] branch main updated: Polished

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new a224cfa  Polished
a224cfa is described below

commit a224cfafa52f5660bed1babac9d7aaffc70c75d7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Dec 16 14:41:08 2021 +0100

    Polished
---
 .../camel/management/mbean/ManagedBacklogDebugger.java      | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java
 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java
index 22184e0..da725db 100644
--- 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java
+++ 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java
@@ -17,7 +17,6 @@
 package org.apache.camel.management.mbean;
 
 import java.io.ByteArrayOutputStream;
-import java.io.IOException;
 import java.io.ObjectOutputStream;
 import java.util.Map;
 import java.util.Set;
@@ -303,13 +302,13 @@ public class ManagedBacklogDebugger implements 
ManagedBacklogDebuggerMBean {
 
     @Override
     public Object evaluateExpressionAtBreakpoint(String id, String language, 
String expression, String resultType) {
-        Exchange suspendedExchange = null;
+        Exchange suspendedExchange;
         try {
             Language lan = camelContext.resolveLanguage(language);
             suspendedExchange = backlogDebugger.getSuspendedExchange(id);
             if (suspendedExchange != null) {
-                Object result = null;
-                Class resultClass = 
camelContext.getClassResolver().resolveClass(resultType);
+                Object result;
+                Class<?> resultClass = 
camelContext.getClassResolver().resolveMandatoryClass(resultType);
                 if (!Boolean.class.isAssignableFrom(resultClass)) {
                     Expression expr = lan.createExpression(expression);
                     expr.init(camelContext);
@@ -329,17 +328,17 @@ public class ManagedBacklogDebugger implements 
ManagedBacklogDebuggerMBean {
                 return result;
             }
         } catch (Exception e) {
-            return e;
+            return e.getMessage();
         }
         return null;
     }
 
-    private boolean isSerializable(Object obj) {
+    private static boolean isSerializable(Object obj) {
         final ByteArrayOutputStream baos = new ByteArrayOutputStream(512);
         try (ObjectOutputStream out = new ObjectOutputStream(baos)) {
             out.writeObject(obj);
             return true;
-        } catch (final IOException ex) {
+        } catch (Exception e) {
             return false;
         }
     }