Example how can i process multiple messages parallel

[bkalas]

Hi, i was able to process messages with these signature:
@Incoming("testchannel") @Outgoing("testResponseChannel") public CompletionStage<Message<String>> onMessage(Message<String> message) { //process incoming message and return message for outgoing channel
But i would like to do this concurrently, in parallel read x messages from incoming channel and process them. I would really appreciate some simple example how this can be achieved. Or is this not recomended way for some reason? Cause i cannot find single example for this