question: public void send ( Set recipients , boolean multicast ) throws InterruptedException , ReplyException { if ( Thread . interrupted ( ) ) { throw new InterruptedException ( ) ; } this . op = operationType . DRAIN_POOL ; Set recips = new HashSet ( recipients ) ; DistributedMember me = originDm . getDistributionManagerId ( ) ; if ( recips . contains ( me ) ) { recips . remove ( me ) ; } rp = new ReplyProcessor21 ( originDm , recips ) ; processorId = rp . getProcessorId ( ) ; setRecipients ( recips ) ; setMulticast ( multicast ) ; originDm . putOutgoing ( this ) ; rp . waitForReplies ( ) ; }
target:  send the message and wait for replies