Throttle @JmsListener in spring (prevent TaskRejectedException)

Question

I currently have a JMSListener configured with the following threadpool:

    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5);
    executor.setMaxPoolSize(10);
    executor.initialize();

The queue I'm listening to has well over 100 messages, and when I start the listener it will process the first 10 messages with no problems, and then I will get TaskRejectedException exceptions for the the remaining messages.

My intent is that @JmsListener should not pull any new messages if there are no available threads to process said message. Does anyone know if this configuration is possible? I'm using version 1.5.3 of springboot.

-TIA

Gary Russell Gary Russell · Accepted Answer · 2017-12-20T19:09:32

If you don't want to lose messages you should not use an executor at all; the container will ack each message as soon as it is queued in the executor. If the system dies, any messages not yet processed will be lost.

Instead, use the container's concurrency settings to multi-thread your listener.

If you really must use an executor and don't mind losing messages, use a caller-runs policy in the executor - setRejectedExecutionHandler().

Throttle @JmsListener in spring (prevent TaskRejectedException)

1 Answers