Thread.sleep(0, 50);
} catch (InterruptedException e) {
log.debug(e.getMessage());
}
}
<BUG>result.sampleEnd();
result.setResponseMessage(loop + " samples messages received");

for(cnt = 0; cnt < loop ; cnt++) {
</BUG>
TextMessage msg = this.SUBSCRIBER.getMessage();

Thread.sleep(0, 50);
} catch (InterruptedException e) {
log.debug(e.getMessage());
}
}
result.sampleEnd();
int read = SUBSCRIBER.count(0);
result.setResponseMessage(read + " samples messages received");
for(cnt = 0; cnt < read ; cnt++) {
TextMessage msg = this.SUBSCRIBER.getMessage();
