docs: public SIMPIterator getQueuedMessageIterator() throws SIMPRuntimeOperationFailedException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "getQueuedMessageIterator");
  
      List<ControlAdapter> messages = new ArrayList<ControlAdapter>();
      NonLockingCursor cursor = null;
      try
      {
        cursor = _aoStream.itemStream.newNonLockingItemCursor(null);
        cursor.allowUnavailableItems();
        AOValue item = (AOValue)cursor.next();
        while(item != null)
        {
          try
          {
            // It's possible to get a null adapter back 
            ControlAdapter cAdapter = item.getControlAdapter();
            if(cAdapter != null)
              messages.add(cAdapter);
            
            item = (AOValue)cursor.next();
          }
          catch (NotInMessageStore ef)
          {
            // No FFDC code needed
            // The message has already been consumed. Trace the exception but allow processing to continue.
            SibTr.exception(tc, ef);
          }
        }      
      }
      catch (MessageStoreException e)
      {
        FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.RemoteConsumerTransmit.getQueuedMessageIterator",
          "1:467:1.44", 
          this);
          
        SIMPRuntimeOperationFailedException e1 =
          new SIMPRuntimeOperationFailedException(
            nls.getFormattedMessage(
              "INTERNAL_MESSAGING_ERROR_CWSIP0003",
              new Object[] {"RemoteConsumerTransmit.getQueuedMessageIterator",
                            "1:475:1.44", 
                            e,
                            _aoStream.streamId},
              null), e);
              
        SibTr.exception(tc, e1);
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "getQueuedMessageIterator", e1);
        throw e1;
      }
      finally
      {
        if (cursor != null)
          cursor.finished();               
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "getQueuedMessageIterator");
        
      return new BasicSIMPIterator(messages.iterator());    
    }