Artem Bilan
Artem Bilan
As you see the logic there is like this: ``` @Nullable private ScheduledFuture timeoutTask(RabbitFuture future) { if (this.receiveTimeout > 0) { this.lock.lock(); try { if (!this.running) { this.pending.remove(future.getCorrelationId()); throw new...
@mailingfeng , Thank you for investigation! I will into that code today. However we are not going to back-port the fix into `2.4.x` branch. That version is out of Open...
I think this was fixed via: https://github.com/spring-projects/spring-amqp/issues/2724 and released as a part of the `3.1.6`. So, treating this as a `Duplication` and close respectively. As I said: this is not...
From that description it sounds like the use-case is pretty complex, so would be great to have some simple project from you to play with. Does it work well if...
OK. So, then my request for a simple project is the next step what we can do over here.
According to the code there is no observation on sending a reply from the Rabbit listener method, so I'm failing to understand how it may work without a `CompletableFuture`. Do...
For better understanding that problem, I'd like to see what you want to have fixed in Spring AMQP and how that would help the target end-user consumer? Any chances elaborating...
@madanhk18 , I said before: we cannot assign to the issue someone who is not team member. Please, stop asking about that. As you see according to my comment it...
> Knowing the reason why a message was redelivered is helpful OK. So, you mean to do `Thread.currentThread().interrupt();` in the main loop of the listener container before calling end-user listener...
Thanks for explanation, @jonenst ! I understand the current behavior you show, without an ability to really interrupt end-user code. So, apparently my assumption that you want `Thread.currentThread().interrupt();` in the...