fix test

streamnative · Aug 5, 2022 · 0dba887 · 0dba887
1 parent 50b0534
commit 0dba887
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/utils/ExchangeUtil.java b/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/utils/ExchangeUtil.java
@@ -16,6 +16,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.json.JsonMapper;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.qpid.server.exchange.ExchangeDefaults;
@@ -76,16 +77,24 @@ public static String covertObjectValueAsString(Object obj) {
             }
             return JSON_MAPPER.writeValueAsString(obj);
         } catch (Exception e) {
+            log.error("Failed to covert object: {}", e.getMessage());
             throw new RuntimeException(e);
         }
     }
 
     public static <T> T covertStringValueAsObject(String value, Class<T> clazz) {
-        return JSON_MAPPER.convertValue(value, clazz);
+        try {
+            if (List.class.isAssignableFrom(clazz)) {
+                return JSON_MAPPER.readValue(value, clazz);
+            }
+            return JSON_MAPPER.convertValue(value, clazz);
+        } catch (Exception e) {
+            log.error("Failed to covert string: {}", e.getMessage());
+            throw new RuntimeException(e);
+        }
     }
 
     public static Object covertStringValueAsObject(String value) {
         return covertStringValueAsObject(value, Object.class);
     }
-
 }