[JAMES-4036] MailSpooler shutdown not graceful

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.7.4, 3.8.1, 3.7.5
• Fix Version/s: 3.7.3, 3.8.2
• Component/s: Mailet Contributions, MailStore & MailRepository, SpoolManager & Processors
• Labels: Apache james mail spool
• Environment: windows 10 and debian 11, oracle jdk 17,21 openjdk 17,21,22
• Assignee: Unassigned
• Reporter: ilya terskov
• Created: 21/May/24 09:09
• Updated: 14/Jun/24 07:30
• Resolved: 14/Jun/24 07:30

Description

13:45:48.520 ←[34m[INFO ]←[0;39m o.a.j.m.i.JamesMailSpooler - start dispose() ...
13:45:48.525 ←[34m[INFO ]←[0;39m o.a.j.m.i.JamesMailSpooler - Cancel queue consumption...
13:45:48.525 ←[34m[INFO ]←[0;39m o.a.j.m.i.JamesMailSpooler - Queue consumption canceled, shutting down processor threads...
13:45:48.528 ←[1;31m[ERROR]←[0;39m r.c.p.Operators - Operator called default onErrorDropped
java.lang.InterruptedException: null
at java.base/java.lang.Object.wait0(Native Method)
at java.base/java.lang.Object.wait(Object.java:375)
at java.base/java.lang.Object.wait(Object.java:348)
at org.apache.activemq.FifoMessageDispatchChannel.dequeue(FifoMessageDispatchChannel.java:72)
at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:497)
... 14 common frames omitted
Wrapped by: javax.jms.JMSException: java.lang.InterruptedException
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:80)
at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:534)
at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:662)
at org.apache.james.queue.jms.JMSCacheableMailQueue.deQueueOneItem(JMSCacheableMailQueue.java:246)
... 12 common frames omitted
Wrapped by: org.apache.james.queue.api.MailQueue$MailQueueException: Unable to dequeue next message
at org.apache.james.queue.jms.JMSCacheableMailQueue.deQueueOneItem(JMSCacheableMailQueue.java:261)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.FluxRepeatPredicate$RepeatPredicateSubscriber.resubscribe(FluxRepeatPredicate.java:120)
at reactor.core.publisher.MonoRepeatPredicate.subscribeOrReturn(MonoRepeatPredicate.java:48)
at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:55)
at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1570)
Wrapped by: reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.james.queue.api.MailQueue$MailQueueException: Unable to dequeue next message;
nested exception is:
javax.jms.JMSException: java.lang.InterruptedException
13:45:48.537 ←[34m[INFO ]←[0;39m o.a.j.m.i.JamesMailSpooler - Thread shutdown completed. Turning off mail queue.
13:45:48.553 ←[34m[INFO ]←[0;39m o.a.j.GuiceJamesServer - JAMES server stopped

Issue Links

• links to: GitHub Pull Request #2251
• links to: GitHub Pull Request #2274