Commit e0aba5d1 authored by Nikhil Singh[MicroSoft]'s avatar Nikhil Singh[MicroSoft]
Browse files

more logs

parent ff661647
Pipeline #61922 passed with stages
in 20 minutes and 9 seconds
......@@ -92,7 +92,7 @@ spec:
- name: executor_n_threads
value: "32"
- name: max_lock_renew_duration_seconds
value: "2000"
value: "500"
- name: initial_subscription_manager_delay_seconds
value: "0"
- name: consecutive_subscription_manager_delay_seconds
......
......@@ -49,7 +49,10 @@ public class MessageHandler implements IMessageHandler {
return this.receiveClient.completeAsync(message.getLockToken());
} catch (Exception e) {
if (message.getDeliveryCount() >= 9) {
LOGGER.info("Moving msg to Dead letter" + message.getMessageId());
LOGGER.info("Moving msg to Dead letter with count 9" + message.getMessageId());
}
if (message.getDeliveryCount() >= 10) {
LOGGER.info("Moving msg to Dead letter with 10 count" + message.getMessageId() + "del count" + message.getDeliveryCount());
}
LOGGER.info("Time elapsed for unsuccessful notif is : " + stopWatch.getTime(TimeUnit.MILLISECONDS) + " of subscription :" + receiveClient.getSubscriptionName() + " with message Id " + message.getMessageId());
stopWatch.stop();
......
......@@ -59,6 +59,7 @@ public class ProcessNotification {
HttpResponse response = notificationHandler.notifySubscriber(notificationContent.getNotificationId(),
notificationContent.getData(), notificationContent.getExtractAttributes());
if (!response.isSuccessCode()) {
LOGGER.error("Message failed with subs id" + subscriptionName + "and msg id" + message.getMessageId() + response);
throw new Exception(NOT_ACKNOWLEDGE);
}
} catch (Exception e) {
......
Markdown is supported
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