question: public void send ( Set recipients , boolean multicast ) throws InterruptedException , ReplyException { final boolean isDebugEnabled = logger . isDebugEnabled ( ) ; if ( Thread . interrupted ( ) ) throw new InterruptedException ( ) ; recipients = new HashSet ( recipients ) ; DistributedMember me = originDm . getDistributionManagerId ( ) ; if ( recipients . contains ( me ) ) { recipients . remove ( me ) ; } if ( isDebugEnabled ) { logger . debug ( "Recipients for SerialAckedMessage are {}" , recipients ) ; } rp = new ReplyProcessor21 ( originDm , recipients ) ; processorId = rp . getProcessorId ( ) ; setRecipients ( recipients ) ; setMulticast ( multicast ) ; Set failures = originDm . putOutgoing ( this ) ; if ( failures != null && failures . size ( ) > 0 ) { for ( Iterator i = failures . iterator ( ) ; i . hasNext ( ) ; ) { InternalDistributedMember mbr = ( InternalDistributedMember ) i . next ( ) ; if ( isDebugEnabled ) { logger . debug ( "Unable to send serial acked message to {}" , mbr ) ; } } } rp . waitForReplies ( ) ; }
target:  send the message and wait for replies