docs: public synchronized AsynchConsumerProxyQueue createReadAheadProxyQueue(Reliability unrecoverableReliability) // f187521.2.1
        throws SIResourceException, SIIncorrectCallException
  	{
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "createReadAheadProxyQueue");
        checkClosed();
        
        // begin D249096
        short id = nextId();
        AsynchConsumerProxyQueue proxyQueue = 
           new ReadAheadSessionProxyQueueImpl(this, id, conversation, unrecoverableReliability);   // f187521.2.1 // f191114
        // end D249096
        
        idToProxyQueueMap.put(new ImmutableId(id), proxyQueue);
        
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createReadAheadProxyQueue", proxyQueue);
        return proxyQueue;      
  	}