code: public void closeConsumers()
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "closeConsumers");
  
      //This must be a rme
      for(Iterator i=_anycastInputHandlers.keySet().iterator(); i.hasNext(); )
      {
        AnycastInputHandler next = _anycastInputHandlers.get(i.next());
        ConsumerDispatcher rcd = next.getRCD();
        
        rcd.closeAllConsumersForDelete(_baseDestinationHandler);
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "closeConsumers");
  
      return;
    }
docs: /* (non-Javadoc)
  @see com.ibm.ws.sib.processor.impl.destination.AbstractRemoteSupport#closeConsumers()