public void deleteSet ( int requestNumber , SIMessageHandle [ ] msgHandles , int tran , boolean reply ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( this , tc , "deleteSet" , new Object [ ] { requestNumber , msgHandles , tran , reply } ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( this , tc , "Request to delete " + msgHandles . length + " message(s)" ) ; if ( reply ) SibTr . debug ( this , tc , "Client is expecting a reply" ) ; } try { SITransaction siTran = ( ( ServerLinkLevelState ) getConversation ( ) . getLinkLevelAttachment ( ) ) . getTransactionTable ( ) . get ( tran ) ; if ( siTran != IdToTransactionTable . INVALID_TRANSACTION ) { getConsumerSession ( ) . deleteSet ( msgHandles , siTran ) ; } try { if ( reply ) { getConversation ( ) . send ( poolManager . allocate ( ) , JFapChannelConstants . SEG_DELETE_SET_R , requestNumber , JFapChannelConstants . PRIORITY_MEDIUM , true , ThrottlingPolicy . BLOCK_THREAD , null ) ; } } catch ( SIException e ) { FFDCFilter . processException ( e , CLASS_NAME + ".deleteSet" , CommsConstants . CATPROXYCONSUMER_DELETESET_02 , this ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , e . getMessage ( ) , e ) ; SibTr . error ( tc , "COMMUNICATION_ERROR_SICO2014" , e ) ; } } catch ( SIException e ) { //No FFDC code needed //Only FFDC if we haven't received a meTerminated event. if ( ! ( ( ConversationState ) getConversation ( ) . getAttachment ( ) ) . hasMETerminated ( ) ) { FFDCFilter . processException ( e , CLASS_NAME + ".deleteSet" , CommsConstants . CATPROXYCONSUMER_DELETESET_01 , this ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , e . getMessage ( ) , e ) ; if ( reply ) { StaticCATHelper . sendExceptionToClient ( e , CommsConstants . CATPROXYCONSUMER_DELETESET_01 , getConversation ( ) , requestNumber ) ; } else { SibTr . error ( tc , "UNABLE_TO_DELETE_MSGS_SICO2007" , e ) ; StaticCATHelper . sendAsyncExceptionToClient ( e , CommsConstants . CATPROXYCONSUMER_DELETESET_01 , // d186970 getClientSessionId ( ) , getConversation ( ) , 0 ) ; // d172528 } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( this , tc , "deleteSet" ) ; }
This method will inform the ME that we have consumed messages that are currently locked on our behalf .