private void reconstituteRemoteQueuePoints ( int startMode , boolean isSystem ) throws SIDiscriminatorSyntaxException , MessageStoreException , SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "reconstituteRemoteQueuePoints" , new Object [ ] { Integer . valueOf ( startMode ) , Boolean . valueOf ( isSystem ) , this } ) ; // Next look for any remote transmission itemstreams to queue points int transmissionQCount = 0 ; PtoPXmitMsgsItemStream ptoPXmitMsgsItemStream = null ; // There can be one or more transmission itemstreams in the BaseDestinationHandler. NonLockingCursor cursor = _baseDestinationHandler . newNonLockingItemStreamCursor ( new ClassEqualsFilter ( PtoPXmitMsgsItemStream . class ) ) ; do { ptoPXmitMsgsItemStream = ( PtoPXmitMsgsItemStream ) cursor . next ( ) ; if ( ptoPXmitMsgsItemStream != null ) { ptoPXmitMsgsItemStream . reconstitute ( _baseDestinationHandler ) ; if ( ptoPXmitMsgsItemStream . isToBeDeleted ( ) ) { ptoPXmitMsgsItemStream . setDeleteRequiredAtReconstitute ( true ) ; SIBUuid8 remoteMEUuid = ptoPXmitMsgsItemStream . getLocalizingMEUuid ( ) ; _postMediatedItemStreamsRequiringCleanup . put ( remoteMEUuid , ptoPXmitMsgsItemStream ) ; _baseDestinationHandler . setHasReconciledStreamsToBeDeleted ( true ) ; _localisationManager . attachRemotePtoPLocalisation ( ptoPXmitMsgsItemStream , _remoteSupport ) ; // Reconstitute source streams for PtoPOutputHandler _remoteSupport . reconstituteSourceStreams ( startMode , ( PtoPOutputHandler ) ptoPXmitMsgsItemStream . getOutputHandler ( ) ) ; assignQueuePointOutputHandler ( ptoPXmitMsgsItemStream . getOutputHandler ( ) , ptoPXmitMsgsItemStream . getLocalizingMEUuid ( ) ) ; } else { transmissionQCount ++ ; _localisationManager . attachRemotePtoPLocalisation ( ptoPXmitMsgsItemStream , _remoteSupport ) ; // Reconstitute source streams for PtoPOutputHandler _remoteSupport . reconstituteSourceStreams ( startMode , ( PtoPOutputHandler ) ptoPXmitMsgsItemStream . getOutputHandler ( ) ) ; /* Feature 176658.3.2 */ assignQueuePointOutputHandler ( ptoPXmitMsgsItemStream . getOutputHandler ( ) , ptoPXmitMsgsItemStream . getLocalizingMEUuid ( ) ) ; //Restore the guess sets for system destinations if ( isSystem ) { _localisationManager . addMEToQueuePointGuessSet ( ptoPXmitMsgsItemStream . getLocalizingMEUuid ( ) ) ; _localisationManager . addMEToRemoteQueuePointGuessSet ( ptoPXmitMsgsItemStream . getLocalizingMEUuid ( ) ) ; } } } } while ( ptoPXmitMsgsItemStream != null ) ; cursor . finished ( ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "reconstituteRemoteQueuePoints" ) ; }
Reconstitute any remote queue points .