public void testSendReceive() throws Exception {
  messages.clear();
  for (int i=0; i < data.length; i++) {
    Message message=session.createTextMessage(data[i]);
    message.setStringProperty("stringProperty",data[i]);
    message.setIntProperty("intProperty",i);
    if (verbose) {
      if (LOG.isDebugEnabled()) {
        LOG.debug("About to send a message: " + message + " with text: "+ data[i]);
      }
    }
    sendToProducer(producer,producerDestination,message);
    messageSent();
  }
  assertMessagesAreReceived();
  LOG.info("" + data.length + " messages(s) received, closing down connections");
}

public void testSendReceive ( ) throws Exception { messages . clear ( ) ; for ( int i = 0 ; i < data . length ; i ++ ) { Message message = session . createTextMessage ( data [ i ] ) ; message . setStringProperty ( "stringProperty" , data [ i ] ) ; message . setIntProperty ( "intProperty" , i ) ; if ( verbose ) { if ( LOG . isDebugEnabled ( ) ) { LOG . debug ( "About to send a message: " + message + " with text: " + data [ i ] ) ; } } sendToProducer ( producer , producerDestination , message ) ; messageSent ( ) ; } assertMessagesAreReceived ( ) ; LOG . info ( "" + data . length + " messages(s) received, closing down connections" ) ; }
sends and consumes the messages .
