code: public void closeRemoteConsumers(Set newQueuePointLocalisingMEUuids,
                                     LocalisationManager daManager)
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, 
                    "closeRemoteConsumers", 
                    new Object[]{ 
                      newQueuePointLocalisingMEUuids,
                      daManager});
  
      Iterator existingMEs = _anycastInputHandlers.keySet().iterator();
      Iterator newMEs = newQueuePointLocalisingMEUuids.iterator();
      
      while (existingMEs.hasNext())
      {
        boolean found = false;
        String key = (String) existingMEs.next();
        AnycastInputHandler aih = _anycastInputHandlers.get(key);
        SIBUuid8 dmeUuid = aih.getLocalisationUuid();
        
        while (newMEs.hasNext())
        {
          SIBUuid8 newMEUuid = new SIBUuid8((String)newMEs.next());
          
          if (newMEUuid.equals(dmeUuid))
          {
            found = true;
            break;
          }
        }
        
        if (!found)
        {
          //Check if the uuid is still advertised in WLM and only close the consumers
          //if it isnt.
          if(!daManager.isQueuePointStillAdvertisedForGet(dmeUuid))
          {
            closeRemoteConsumer(key);
          }
        }
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "closeRemoteConsumers");
  
      return;
    }
docs: Method closeRemoteConsumers
  <p>Close any consumers that are consuming remotely from a partition of the queue
  that has now been deleted