public boolean sendToMatching ( Msg msg ) { // Is this end of a multipart message? boolean msgMore = msg . hasMore ( ) ; // Push the message to matching pipes. distribute ( msg ) ; // If mutlipart message is fully sent, activate all the eligible pipes. if ( ! msgMore ) { active = eligible ; } more = msgMore ; return true ; }
Send the message to the matching outbound pipes .