public void removeKeyGroup ( LocalQPConsumerKeyGroup keyGroup ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "removeKeyGroup" , keyGroup ) ; // Take the lock to prevent another thread from trying to add a member to // the group while we're removing it synchronized ( _baseDestHandler . getReadyConsumerPointLock ( ) ) { // Need to find the correct object to remove. Iterator keys = keyGroups . keySet ( ) . iterator ( ) ; while ( keys . hasNext ( ) ) { Object key = keys . next ( ) ; if ( keyGroups . get ( key ) . equals ( keyGroup ) ) keys . remove ( ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "removeKeyGroup" ) ; }
Remove the keyGroup from the CD this occurs when the last member is removed from the group