Similiar to #465, it would be great if for the RabbitMQ connector we could automatically deserialize a JSON Payload to a given complex object type.
Something like:
@Incoming("prices")
public CompletionStage<Void> consume(Message<Price> price) {
//...
}
class Price {
double amount;
}
Currently we can only declare the payload of incoming RabbitMQ Message as: byte[], String, JsonObject, JsonArray