quarkus: @ConsumeEvent does not work in native when returning a Uni>

@mkouba Thank you, It works.

It seems that we only register the LocalEventBusCodec for the return type of a consumer method, i.e. for java.util.Set in this particular case. However, when Vert.x attempts to lookup the codec for the message it’s using the actual type of the message body; i.e. java.util.HashSet in this reproducer. As a result, in the JVM mode the SerializableCodec is used as the fallback (because HashSet implements java.io.Serializable) but this obviously does not work in native mode.

@tnmtechnologies In theory, you don’t need to create the MySet class but merely change the return type of the consumer method to Uni<HashSet<String>>.

@cescoffier I’m not quite sure if we could do something to improve the UX in similar cases…

The issue is the usage of Set<String> as reply. The local codec does not seem to work in this case in native. We need to have a look (probably with the help of @mkouba ).

If you use something like:

public static class MySet extends HashSet<String> {
        public MySet() {
            super();
        }

        public MySet(Set<String> s) {
            super(s);
        }

    }

    /**
     *
     */
    @ConsumeEvent("getIds")
    public Uni<MySet> getIds(final JsonObject message) {
        Log.infov("getIds(message={0})", message);

        final Long limit = Optional.ofNullable(message.getLong("limit")).orElse(Long.MAX_VALUE);
        final String type = message.getString("type");

        return Optional.ofNullable(type)
                    .map(t -> {
                        final ReactiveSetCommands<String,String> setCommands = rds.set(String.class);
                        return setCommands.smembers(TYPE_NAMESPACE + t);
                    }).orElseGet(() -> {
                        final ReactiveKeyCommands<String> keyCommands = rds.key(String.class);                        
                        final ReactiveKeyScanCursor<String> scanCursor = keyCommands.scan(new KeyScanArgs().match(ID_NAMESPACE + '*').count(Long.MAX_VALUE));
                        final boolean hasNext = scanCursor.hasNext();
                        System.out.println("Has next...");
                        return hasNext ? scanCursor.next() : Uni.createFrom().item(() -> Collections.emptySet());
                    }).onItem().transformToMulti(s -> Multi.createFrom().items(s::stream))
                    .select().first(limit)
                    .onItem().transform(s -> type != null ? s : s.substring(ID_NAMESPACE.length()))
                    .collect().asSet()
                    .map(s -> new MySet(s))
                    .log("user code")
                    ;
    }

It works

Yes everything works properly in JVM mode.