public void handleSilence ( MessageItem msgItem ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( this , tc , "handleSilence" , new Object [ ] { msgItem } ) ; JsMessage jsMsg = msgItem . getMessage ( ) ; int priority = jsMsg . getPriority ( ) . intValue ( ) ; Reliability reliability = jsMsg . getReliability ( ) ; StreamSet streamSet = getStreamSetForMessage ( jsMsg ) ; if ( streamSet != null ) { TargetStream targetStream = null ; synchronized ( streamSet ) { targetStream = ( TargetStream ) streamSet . getStream ( priority , reliability ) ; } if ( targetStream != null ) { // Update the stateStream with Silence targetStream . writeSilence ( msgItem ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "handleSilence" ) ; }
Handle a filtered message by inserting it in to the appropriate target stream as Silence . Since we only need to do this on exisiting TargetStreams if the streamSet or stream are null we give up