public void test() throws Exception
{
for (int i = 0; i < 100000; i++)
{
log.info("**** ITER " + i + " \n\n\n\n\n");
this.testSendMessageWithContentLength();
tearDown();
setUp();
}
}
Increase the timeout to 10000, 1000 is too short anyway, since we *expect* to receive the message we should never use short timeouts - these are prone to sporadic failures due to slow machines and scheduling
BytesMessage message = (BytesMessage)consumer.receive(10000);
Assert.assertNotNull(message);
assertEquals(data.length, message.getBodyLength());