Fix for: https://issues.apache.org/activemq/browse/AMQ-1738

Messages stuck in a queue don't get dispatch (happens when consumers close out)


git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@658370 13f79535-47bb-0310-9956-ffa450edef68

activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java

@@ -138,6 +138,11 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
 
     public void add(MessageReference node) throws Exception {
         synchronized (pendingLock) {
+            // The destination may have just been removed...  
+            if( !destinations.contains(node.getRegionDestination()) ) {
+                // perhaps we should inform the caller that we are no longer valid to dispatch to?
+                return;
+            }
             enqueueCounter++;
             pending.addMessageLast(node);    
         }