search

Azure / azure-service-bus-java

☁️ Java client library for Azure Service Bus
https://azure.microsoft.com/services/service-bus
MIT License
60 stars 59 forks source link

Azure Service Bus - ServiceBusProcessorClient-Java- Trytimeout and processing concurrent sessions #434

Open martinkcc opened 5 months ago

martinkcc commented 5 months ago

I am using ServiceBusProcessorClient and AmqpRetryOptions to connect my Azure Service Bus. Facing two issues.

Consumer waits for 30 seconds to process the next message from ASB. Is this due to trytimeout settings? I set to 30 seconds as once we get a message from ASB we call an API and that can sometimes take 30 seconds to respond.

When I have concurrent sessions and max concurrent calls as 4, it will take 4 messages from ASB, but if one of them fails, in the exception block , I do a serviceBusProcessorClient.close() which will stop the consumer and in this case, it will put all 4 messages back in ASB, rather then just the failed one. Any solution available?

ampqRetryOptions.setDelay(Duration.ofSeconds(Integer.parseInt(serviceBusConfig.getAmpqDelay())));
        ampqRetryOptions.setMaxRetries(<5>);
        ampqRetryOptions.setMaxDelay(<1>);
        ampqRetryOptions.setMode(AmqpRetryMode.EXPONENTIAL);
        ampqRetryOptions.setTryTimeout(<30 seconds>);
serviceBusProcessorClient = new ServiceBusClientBuilder()
                .connectionString(connectioString).retryOptions(ampqRetryOptions)
                .sessionProcessor().maxConcurrentSessions(4))
                .maxConcurrentCalls(4))
                .queueName(<queueName>)
                .maxAutoLockRenewDuration(50 seconds)
                .processMessage(onMessage()).disableAutoComplete()
                .processError(onError)
                .buildProcessorClient();