public AmqpMessage receive() throws Exception {
  checkClosed();
  return prefetch.take();
}

public AmqpMessage receive ( ) throws Exception { checkClosed ( ) ; return prefetch . take ( ) ; }
attempts to wait on a message to be delivered to this receiver . the receive call will wait indefinitely for a message to be delivered .
