Commit 19718cd7 authored by harshit aggarwal's avatar harshit aggarwal
Browse files

updating topic -4

parent de260f17
Pipeline #22446 failed with stages
in 51 seconds
......@@ -102,8 +102,8 @@ spec:
- name: default_tenant
value: {{ .Values.default_tenant }}
- name: max_concurrent_calls
value: "32"
value: "64"
- name: executor_n_threads
value: "32"
value: "64"
- name: max_lock_renew_duration_seconds
value: "600"
value: "6000"
......@@ -57,7 +57,11 @@ public class SubscriptionManagerImpl implements SubscriptionManager {
MessageHandler messageHandler = new MessageHandler(subscriptionClient, processWKSTransform);
subscriptionClient.registerMessageHandler(
messageHandler,
new MessageHandlerOptions(Integer.parseUnsignedInt(azureBootstrapConfig.getMaxConcurrentCalls()), false, Duration.ofSeconds(Integer.parseUnsignedInt(azureBootstrapConfig.getMaxLockRenewDurationInSeconds()))),
new MessageHandlerOptions(Integer.parseUnsignedInt(azureBootstrapConfig.getMaxConcurrentCalls()),
false,
Duration.ofSeconds(Integer.parseUnsignedInt(azureBootstrapConfig.getMaxLockRenewDurationInSeconds())),
Duration.ofMillis(200)
),
executorService);
} catch (InterruptedException | ServiceBusException e) {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment