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 ; }
Creates a new read ahead proxy queue for this group .