Mahesh Daksha
Mahesh Daksha
Hello Anu Thomas, Thank you for your response. Yes, the steps you mentioned are correct. The *batch size I am passing is 100*. So basically each of the 5 threads...
Hello @anuchandy , Thank you for your response, I have studied through the details. Please check the below point and help me with your response. 1. [Fixing the hang issue...
> @dakshme, btw, could you let me know the service tier? Pricing tier is **Standard** for us (at least in the env I am working).
@anuchandy Thank you for point out the documentation. In my case for now I am not seeing any related issues indicating credit limit exhausted. I understand that in standard tier...
@anuchandy Yes your test program looks close to what I am doing here. Just additional I have used cyclic barrier on top of regular executor service. So we are good...
Hello @anuchandy, To answer above question: 1. Yes, I am doing with the approach of each thread having its own receiver client. So basically if I have 5 thread then...
Hello @anuchandy , In continuation with the above implementation, in my implementation (`this.messageReceiver.receiveMessages(batch, Duration.ofMillis(500))`) I have kept max wait time as 500 miliseconds. With this configuration the receiver client works...
@anuchandy can you please help me with above query,
@anuchandy Thank you for your response. I already made the max wait time to 5 seconds but I see that with this config the said issue i.e. `AmqpMessagePartitioningEntityMessageCache.IdleTimerExpired: Idle timeout...
@anuchandy Since the 7.15 dev was in beta mode so we purposefully switched back to earlier one. But after your last reply I changed the implementation to use the latest...