From 5057c4a69cc9b69523916255b0a7aed4627d623c 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)

---
 .../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 5b6307d10c..3f608f0867 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);