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();
}

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 ( ) ; }
send the message and wait for replies
