docs: 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");
     }