protected void resetBusSubscriptionList ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "resetBusSubscriptionList" ) ; // Iterate over the list of Buses for ( int i = 0 ; i < _buses . length ; i ++ ) { BusGroup group = _buses [ i ] ; // Reset the list of subscriptions group . reset ( ) ; try { // Add this list of subscriptions to the list for this bus addSubscriptionsToBus ( group , group . getName ( ) ) ; // Create the reset subscription message for this bus. SubscriptionMessage message = group . generateResetSubscriptionMessage ( ) ; // If there is a reset message to send, then send it. LocalTransaction transaction = _proxyHandler . getMessageProcessor ( ) . getTXManager ( ) . createLocalTransaction ( true ) ; // Send to the list of all neighbours. group . sendToNeighbours ( message , ( Transaction ) transaction , true ) ; transaction . commit ( ) ; } catch ( SIException e ) { // No FFDC code needed SibTr . exception ( tc , e ) ; group . resetListFailed ( ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "resetBusSubscriptionList" ) ; }
Resets the list of subscriptions that the bus knows about .