private void configureNeighbours ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "configureNeighbours" ) ; try { JsAdminService service = JsMainAdminComponentImpl . getJsAdminService ( ) ; // Check that the admin service is initialized before calling it. // Tell TRM the set of messaging engines on the bus _messagingEnginesOnBus = new HashSet < SIBUuid8 > ( ) ; // Add this messaging engine to the list. // messagingEnginesOnBus.add(getMessagingEngineUuid()); Set mes = null ; // Check that the admin service is initialized before calling it. if ( service . isInitialized ( ) ) mes = service . getMessagingEngineSet ( _engine . getBusName ( ) ) ; if ( mes != null ) { Iterator iterator = mes . iterator ( ) ; // Create a transaction for creating the Neighbours with. LocalTransaction transaction = _txManager . createLocalTransaction ( true ) ; // Cycle through the list of messaging engines. while ( iterator . hasNext ( ) ) { SIBUuid8 jsEngineUUID = new SIBUuid8 ( ( String ) iterator . next ( ) ) ; if ( ! jsEngineUUID . equals ( new SIBUuid8 ( _engine . getUuid ( ) ) ) ) { // Create the Neighbour _multiMEProxyHandler . createNeighbour ( jsEngineUUID , _engine . getBusName ( ) , ( Transaction ) transaction ) ; } _messagingEnginesOnBus . add ( jsEngineUUID ) ; } transaction . commit ( ) ; } } catch ( SIException e ) { // FFDC FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.MessageProcessor.configureNeighbours" , "1:2223:1.445" , this ) ; SibTr . exception ( tc , e ) ; SIErrorException finalE = new SIErrorException ( nls . getFormattedMessage ( "MESSAGE_PROCESSOR_CONFIGURE_NEIGHBOURS_ERROR_CWSIP0391" , new Object [ ] { getMessagingEngineName ( ) , e } , null ) , e ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "configureNeighbours" , finalE ) ; SibTr . error ( tc , "MESSAGE_PROCESSOR_CONFIGURE_NEIGHBOURS_ERROR_CWSIP0391" , new Object [ ] { getMessagingEngineName ( ) , SIMPUtils . getStackTrace ( e ) } ) ; throw finalE ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "configureNeighbours" ) ; }
Loads the Neighbours from Admin