DefaultMessageListenerContainer reacts to maxConcurrentConsumers reduction for long-lived tasks (SPR-7075)

org.springframework.jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java

@@ -989,6 +989,9 @@ public class DefaultMessageListenerContainer extends AbstractPollingMessageListe
 					if (wasWaiting) {
 						activeInvokerCount++;
 					}
+					if (scheduledInvokers.size() > maxConcurrentConsumers) {
+						active = false;
+					}
 				}
 				if (active) {
 					messageReceived = (invokeListener() || messageReceived);