Correlation id with Emitter

[marko-lazic]

When trying to add a correlation id to my messages.

@Channel("foo.created")
Emitter<Message<String>> emitter;

....

            String correlationId = UUID.randomUUID().toString();
            Message<String> message =
                Message.of(jsonMessage)
                       .addMetadata(OutgoingAmqpMetadata.builder().withCorrelationId(correlationId).build());
            emitter.send(message);

This returns an exception

Caused by: javax.enterprise.inject.spi.DefinitionException: SRMSG00075: Invalid Emitter injection found for `io.quarkus.arc.impl.CurrentInjectionPointProvider$InjectionPointImpl@36f7a540`. Injecting an `Emitter<Message<T>>` is invalid. You can use an `Emitter<T>` to send instances of `T` and `Message<T>`.

Is there a way to add a correlation id to a message using the Emitter?

[marko-lazic]

I solved it by just setting the emitter generic to String.

@Channel("foo.created")
Emitter<String> emitter;

And the rest of the code is the same. The emitter.send(message) now uses <M extends Message<? extends T>> void send(M msg);