private void createProxyListener ( ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "createProxyListener" ) ; // Create the proxy listener instance _proxyListener = new NeighbourProxyListener ( _neighbours , this ) ; /* * Now we can create our asynchronous consumer to listen on * SYSTEM.MENAME.PROXY.QUEUE Queue for receiving subscription * updates */ // 169897.1 modified parameters try { _proxyAsyncConsumer = _messageProcessor . getSystemConnection ( ) . createSystemConsumerSession ( _messageProcessor . getProxyHandlerDestAddr ( ) , // destination name null , //Destination filter null , // SelectionCriteria - discriminator and selector Reliability . ASSURED_PERSISTENT , // reliability false , // enable read ahead false , null , false ) ; // 169897.1 modified parameters _proxyAsyncConsumer . registerAsynchConsumerCallback ( _proxyListener , 0 , 0 , 1 , null ) ; _proxyAsyncConsumer . start ( false ) ; } catch ( SIException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.proxyhandler.MultiMEProxyHandler.createProxyListener" , "1:1271:1.96" , this ) ; SibTr . exception ( tc , e ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "createProxyListener" , "SIResourceException" ) ; // The Exceptions should already be NLS'd throw new SIResourceException ( e ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "createProxyListener" ) ; }
Method that creates the NeighbourProxyListener instance for reading messages from the Neighbours . It then registers the listener to start receiving messages