public void processMessage(JsMessage jsMsg) throws SIResourceException
   {
     if (tc.isEntryEnabled())
       SibTr.entry(tc, "processMessage", new Object[] { jsMsg });
    
     int priority = jsMsg.getPriority().intValue();
     Reliability reliability = jsMsg.getReliability();
       
     SIBUuid12 streamID = jsMsg.getGuaranteedStreamUUID();
     StreamSet streamSet = getStreamSet(streamID, true);
     
     InternalInputStream internalInputStream = null;
     synchronized(streamSet)
     {
       internalInputStream = (InternalInputStream) streamSet.getStream(priority, reliability);        

       // This may be the first message which has required this stream    
       if(internalInputStream == null && 
        (reliability.compareTo(Reliability.BEST_EFFORT_NONPERSISTENT) > 0))
       {
         internalInputStream = createStream(streamSet, priority, reliability);      
       }
     }
        
     if (tc.isEntryEnabled())
       SibTr.exit(tc, "processMessage");
   }
public void processMessage ( JsMessage jsMsg ) throws SIResourceException { if ( tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "processMessage" , new Object [ ] { jsMsg } ) ; int priority = jsMsg . getPriority ( ) . intValue ( ) ; Reliability reliability = jsMsg . getReliability ( ) ; SIBUuid12 streamID = jsMsg . getGuaranteedStreamUUID ( ) ; StreamSet streamSet = getStreamSet ( streamID , true ) ; InternalInputStream internalInputStream = null ; synchronized ( streamSet ) { internalInputStream = ( InternalInputStream ) streamSet . getStream ( priority , reliability ) ; if ( internalInputStream == null && ( reliability . compareTo ( Reliability . BEST_EFFORT_NONPERSISTENT ) > 0 ) ) { internalInputStream = createStream ( streamSet , priority , reliability ) ; } } if ( tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "processMessage" ) ; }
This method creates a Stream if this is the first
inbound message which has been sent to remote Mes

@param  jsMsg
@throws SIResourceException
@throws SICoreException