ConsumerThread consumer = new ConsumerThread(consumerSess, destination);
consumer.setBreakOnNull(false);
consumer.setMessageCount(messageCount);
producer.start();
producer.join();
consumer.start();
consumer.join();
assertEquals("consumer got all produced messages", producer.getMessageCount(), consumer.getReceived());