From 75c9ff2662f53623f7fad490543d1b95da3a9189 Mon Sep 17 00:00:00 2001
From: Juergen Hoeller <jhoeller@vmware.com>
Date: Thu, 22 Apr 2010 13:27:16 +0000
Subject: [PATCH] DefaultMessageListenerContainer reacts to
 maxConcurrentConsumers reduction for long-lived tasks (SPR-7075)

git-svn-id: https://src.springframework.org/svn/spring-framework/trunk@3286 50f2f4bb-b051-0410-bef5-90022cba6387
---
 .../jms/listener/DefaultMessageListenerContainer.java          | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/org.springframework.jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java b/org.springframework.jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java
index 5b6307d10c1..3f608f08672 100644
--- a/org.springframework.jms/src/main/java/org/springframework/jms/listener/DefaultMessageListenerContainer.java
+++ b/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);