public void testMultipleSubscribers() throws Exception {
SubscriberThread[] subscribers = new SubscriberThread[NUMBER_OF_SUBSCRIBERS];
for (int i = 0; i < NUMBER_OF_SUBSCRIBERS; ++i) {
subscribers[i] = new SubscriberThread(this, BROKER_URL, "topic" + i, consumerPort + i);
subscribers[i].start();
}
Thread.sleep(5000);