[Fix quarkiverse#281] Fixing converter priority

fjtirado · Sep 24, 2024 · f1976e4 · f1976e4
1 parent 57e2c2b
commit f1976e4
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/...main/java/io/quarkus/reactivemessaging/http/runtime/converters/JacksonBasedConverter.java b/...main/java/io/quarkus/reactivemessaging/http/runtime/converters/JacksonBasedConverter.java
@@ -26,5 +26,10 @@ public Message<?> convert(Message<?> in, Type target) {
         }
     }
 
+    @Override
+    public int getPriority() {
+        return CONVERTER_DEFAULT_PRIORITY - 1;
+    }
+
     protected abstract Message<?> doConvert(Message<?> in, Type target);
 }
diff --git a/...e/src/main/java/io/quarkus/reactivemessaging/http/runtime/converters/StringConverter.java b/...e/src/main/java/io/quarkus/reactivemessaging/http/runtime/converters/StringConverter.java
@@ -14,7 +14,6 @@
  */
 @ApplicationScoped
 public class StringConverter implements MessageConverter {
-
     @Override
     public boolean canConvert(Message<?> in, Type target) {
         return in.getPayload() instanceof Buffer && target == String.class;
@@ -24,4 +23,9 @@ public boolean canConvert(Message<?> in, Type target) {
     public Message<String> convert(Message<?> in, Type target) {
         return in.withPayload(((Buffer) in.getPayload()).toString());
     }
+
+    @Override
+    public int getPriority() {
+        return CONVERTER_DEFAULT_PRIORITY - 1;
+    }
 }