srikarasr

``` public ServiceBusProcessorClient getSessionProcessorClient(String topicName, String subscriptionName, Consumer onMessage, Consumer onError) { String connectionString = sbProperties.getConnectionString(); return new ServiceBusClientBuilder() .connectionString(connectionString) .sessionProcessor() .disableAutoComplete() .receiveMode(ServiceBusReceiveMode.PEEK_LOCK) .topicName(topicName) .subscriptionName(subscriptionName) .maxConcurrentSessions(5) .processMessage(onMessage) .processError(onError) .buildProcessorClient(); }...

SDK Version ``` com.azure azure-core 1.16.0 com.azure azure-messaging-servicebus 7.2.1 ```