public void testSendReceive() throws Exception {
  Thread.sleep(1000);
  messages.clear();
  sendMessages();
  assertMessagesAreReceived();
  LOG.info("" + data.length + " messages(s) received, closing down connections");
}

public void testSendReceive ( ) throws Exception { Thread . sleep ( 1000 ) ; messages . clear ( ) ; sendMessages ( ) ; assertMessagesAreReceived ( ) ; LOG . info ( "" + data . length + " messages(s) received, closing down connections" ) ; }
test if all the messages sent are being received .
