281282283284285286287288289290291
} return buffer.toString(); } }; producer.start(); // Give the forwarding clients a chance to get going and fill the down // stream broker queues.. Thread.sleep(BROKER_COUNT*200);
278279280281282283284285286287288