Enhancement Request: support multiple JMS messages read in Reactive Messaging

[satyanarayana-penugonda-eng]

Environment Details

• Helidon Version: 2.5.0
• Helidon MP
• JDK version: 11
• OS: Oracle Linux Server
• Docker version (if applicable):

---

Problem Description

I am working on an application (micro service) which uses Helidon MP 2.5.0 and Helidon JMS connector to consume the JMS messages produced by a weblogic server.
the weblogic server produces 1000 JMS messages per second .
The Helidon micro service application uses 14 JMS consumer channels (for the same destination) and acknowledges the JMS message immediately upon receiving the JMS message.
The Hellidon micro service app able to consume max 100 JMS Message per second .
Increasing the number of the JMS consumer channels further (> 14 ) is decreasing the performance.

Expected Behavior:
Request or receive more than one JMS message at a time using the Helidon JMS connector Consumer channel to increase the throughput.

Steps to reproduce

Consumer channel configuration

  IncomingOutboundQueue14:
        connector: helidon-jms
        session-mode: CLIENT_ACKNOWLEDGE
        destination: jms_module!event_outbound

Java code

  @Incoming("IncomingOutboundQueue14")
    @Acknowledgment(Acknowledgment.Strategy.MANUAL)
    public CompletionStage<Void> onMessage(final JmsMessage<String> message) throws IOException {
        if (log.atInfo().isEnabled()) {
            log.atInfo().log("The IncomingOutboundQueue14 message is started.");
        }
        return message.ack();
        
    }

Porting issues:

• [2.x] Enhancement Request: support multiple JMS messages read in Reactive Messaging #6075
• [4.x] Enhancement Request: support multiple JMS messages read in Reactive Messaging #6076

PRs:

• [3.x] 5895 JMS consumption batching #6074
• [4.x] 6076 JMS consumption batching #6078
• [2.x] 6075 JMS consumption batching #6081

[arjav-desai]

Possible duplicate of #4380