question: 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" ) ; }
target:  Sends and consumes the messages.